[jira] [Resolved] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

2020-04-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9812. Fix Version/s: 2.6.0 Resolution: Fixed > Integration tests hang and timeout the

[jira] [Created] (KAFKA-9799) Flaky Test ResetConsumerGroupOffsetTest#testResetOffsetsToLatest

2020-04-01 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9799: -- Summary: Flaky Test ResetConsumerGroupOffsetTest#testResetOffsetsToLatest Key: KAFKA-9799 URL: https://issues.apache.org/jira/browse/KAFKA-9799 Project: Kafka

[jira] [Resolved] (KAFKA-9759) Add documentation change for KIP-562

2020-03-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9759. Fix Version/s: 2.5.0 Resolution: Fixed > Add documentation change for KIP-562 >

[jira] [Created] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

2020-03-28 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9783: -- Summary: Flaky Test QueryableStateIntegrationTest#concurrentAccesses Key: KAFKA-9783 URL: https://issues.apache.org/jira/browse/KAFKA-9783 Project: Kafka

[jira] [Created] (KAFKA-9776) Producer should automatically downgrade CommitTxRequest

2020-03-27 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9776: -- Summary: Producer should automatically downgrade CommitTxRequest Key: KAFKA-9776 URL: https://issues.apache.org/jira/browse/KAFKA-9776 Project: Kafka

[jira] [Resolved] (KAFKA-9760) Add EOS protocol changes to documentation

2020-03-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9760. Fix Version/s: 2.6.0 Resolution: Fixed > Add EOS protocol changes to documentation

[jira] [Resolved] (KAFKA-9758) Add documentations for KIP-523 and KIP-527

2020-03-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9758. Fix Version/s: 2.5.0 Resolution: Fixed > Add documentations for KIP-523 and KIP-527

[jira] [Resolved] (KAFKA-9736) Use internal consumer config to fail for unsupported protocol

2020-03-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9736. Resolution: Duplicate > Use internal consumer config to fail for unsupported protocol >

[jira] [Created] (KAFKA-9748) Extend EOS integration test for EOS-beta

2020-03-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9748: -- Summary: Extend EOS integration test for EOS-beta Key: KAFKA-9748 URL: https://issues.apache.org/jira/browse/KAFKA-9748 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9741) ConsumerCoordinator must update ConsumerGroupMetadata before calling onPartitionsRevoked()

2020-03-20 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9741: -- Summary: ConsumerCoordinator must update ConsumerGroupMetadata before calling onPartitionsRevoked() Key: KAFKA-9741 URL: https://issues.apache.org/jira/browse/KAFKA-9741

[jira] [Created] (KAFKA-9736) Use internal consumer config to fail for unsupported protocol

2020-03-19 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9736: -- Summary: Use internal consumer config to fail for unsupported protocol Key: KAFKA-9736 URL: https://issues.apache.org/jira/browse/KAFKA-9736 Project: Kafka

[jira] [Resolved] (KAFKA-9441) Refactor commit logic

2020-03-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9441. Fix Version/s: 2.6.0 Resolution: Fixed > Refactor commit logic >

[jira] [Created] (KAFKA-9714) Flaky Test SslTransportLayerTest#testTLSDefaults

2020-03-12 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9714: -- Summary: Flaky Test SslTransportLayerTest#testTLSDefaults Key: KAFKA-9714 URL: https://issues.apache.org/jira/browse/KAFKA-9714 Project: Kafka Issue

[jira] [Resolved] (KAFKA-9682) Flaky Test KafkaBasedLogTest#testSendAndReadToEnd

2020-03-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9682. Resolution: Fixed Closing this as "fixed by" KAFKA-9686 > Flaky Test

[jira] [Resolved] (KAFKA-9686) MockConsumer#endOffsets should be idempotent

2020-03-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9686. Resolution: Fixed > MockConsumer#endOffsets should be idempotent >

[jira] [Resolved] (KAFKA-8019) Better Scaling Experience for KStream

2020-03-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8019. Resolution: Duplicate Closing this a duplicate of KAFKA-6145. Should be address via

[jira] [Created] (KAFKA-9682) Flaky Test KafkaBasedLogTest#testSendAndReadToEnd

2020-03-07 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9682: -- Summary: Flaky Test KafkaBasedLogTest#testSendAndReadToEnd Key: KAFKA-9682 URL: https://issues.apache.org/jira/browse/KAFKA-9682 Project: Kafka Issue

[jira] [Resolved] (KAFKA-9240) Flaky test kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

2020-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9240. Resolution: Duplicate Closing this as duplicate. > Flaky test >

[jira] [Created] (KAFKA-9655) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoConsumeWithoutDescribeAclViaSubscribe

2020-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9655: -- Summary: Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoConsumeWithoutDescribeAclViaSubscribe Key: KAFKA-9655 URL: https://issues.apache.org/jira/browse/KAFKA-9655

[jira] [Created] (KAFKA-9597) Flaky Test KafkaProducerTest#testInitTransactionTimeout

2020-02-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9597: -- Summary: Flaky Test KafkaProducerTest#testInitTransactionTimeout Key: KAFKA-9597 URL: https://issues.apache.org/jira/browse/KAFKA-9597 Project: Kafka

[jira] [Reopened] (KAFKA-9441) Refactor commit logic

2020-02-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9441: The first PR was just part of this ticket. We still need to change the commit logic for

[jira] [Resolved] (KAFKA-8025) Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls

2020-02-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8025. Resolution: Fixed > Flaky Test >

[jira] [Resolved] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

2020-02-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6607. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Streams lag not zero when input

[jira] [Resolved] (KAFKA-9483) Add Scala KStream#toTable to the Streams DSL

2020-02-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9483. Fix Version/s: 2.5.0 Resolution: Fixed > Add Scala KStream#toTable to the Streams

[jira] [Resolved] (KAFKA-9248) Foreign key join does not pickup default serdes and dies with NPE

2020-02-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9248. Resolution: Duplicate Agreed. Closing this ticket as duplicate. > Foreign key join does

[jira] [Resolved] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

2020-02-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8940. Resolution: Fixed Nevermind. The test is fine. The PR broke the test. Can reproduce it

[jira] [Created] (KAFKA-9516) Flaky Test PlaintextProducerSendTest#testNonBlockingProducer

2020-02-06 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9516: -- Summary: Flaky Test PlaintextProducerSendTest#testNonBlockingProducer Key: KAFKA-9516 URL: https://issues.apache.org/jira/browse/KAFKA-9516 Project: Kafka

[jira] [Reopened] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

2020-02-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8940: Reopening. Failed again: 

[jira] [Created] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

2020-02-05 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9512: -- Summary: Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration Key: KAFKA-9512 URL: https://issues.apache.org/jira/browse/KAFKA-9512 Project: Kafka

[jira] [Created] (KAFKA-9502) Use explicit "purge data" for windowed changelog topics instead of "delete,compact" topic config

2020-02-03 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9502: -- Summary: Use explicit "purge data" for windowed changelog topics instead of "delete,compact" topic config Key: KAFKA-9502 URL:

[jira] [Created] (KAFKA-9501) Promote Standby tasks to active tasks without closing them

2020-02-03 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9501: -- Summary: Promote Standby tasks to active tasks without closing them Key: KAFKA-9501 URL: https://issues.apache.org/jira/browse/KAFKA-9501 Project: Kafka

[jira] [Created] (KAFKA-9496) Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads

2020-02-02 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9496: -- Summary: Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads Key: KAFKA-9496 URL: https://issues.apache.org/jira/browse/KAFKA-9496

[jira] [Created] (KAFKA-9495) Flaky Test ReassignPartitionsClusterTest#shouldListReassignmentsTriggeredByZk

2020-02-02 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9495: -- Summary: Flaky Test ReassignPartitionsClusterTest#shouldListReassignmentsTriggeredByZk Key: KAFKA-9495 URL: https://issues.apache.org/jira/browse/KAFKA-9495

[jira] [Resolved] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2020-01-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7658. Fix Version/s: 2.5.0 Resolution: Fixed > Add KStream#toTable to the Streams DSL >

[jira] [Resolved] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

2020-01-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9445. Fix Version/s: 2.5.0 Resolution: Fixed > Allow fetching a key from a single

[jira] [Resolved] (KAFKA-8317) ClassCastException using KTable.suppress()

2020-01-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8317. Resolution: Duplicate Closing this ticket in favor of KAFKA-9259 that duplicates it. >

[jira] [Created] (KAFKA-9451) Pass consumer group metadata to producer on commit

2020-01-17 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9451: -- Summary: Pass consumer group metadata to producer on commit Key: KAFKA-9451 URL: https://issues.apache.org/jira/browse/KAFKA-9451 Project: Kafka Issue

[jira] [Created] (KAFKA-9441) Refactor commit logic

2020-01-15 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9441: -- Summary: Refactor commit logic Key: KAFKA-9441 URL: https://issues.apache.org/jira/browse/KAFKA-9441 Project: Kafka Issue Type: Sub-task

[jira] [Reopened] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2020-01-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8677: Reopening this ticket. Test failed again: 

[jira] [Created] (KAFKA-9399) Flaky Test BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild

2020-01-10 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9399: -- Summary: Flaky Test BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild Key: KAFKA-9399 URL: https://issues.apache.org/jira/browse/KAFKA-9399

[jira] [Resolved] (KAFKA-6571) KafkaProducer.close(0) should be non-blocking

2020-01-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6571. Resolution: Duplicate KIP-367 add `close(Duration)` with new non-blocking semantics: 

[jira] [Resolved] (KAFKA-9383) Expose Consumer Group Metadata for Transactional Producer

2020-01-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9383. Fix Version/s: 2.5.0 Resolution: Fixed > Expose Consumer Group Metadata for

[jira] [Resolved] (KAFKA-9068) Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)`

2020-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9068. Fix Version/s: 2.4.1 2.3.2 2.5.0 Resolution:

[jira] [Resolved] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2020-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6049. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Streams: Add Cogroup in the DSL >

[jira] [Created] (KAFKA-9388) Flaky Test StandbyTaskCreationIntegrationTest.shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables

2020-01-08 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9388: -- Summary: Flaky Test StandbyTaskCreationIntegrationTest.shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables Key: KAFKA-9388 URL:

[jira] [Resolved] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime

2020-01-07 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6614. Fix Version/s: 2.5.0 Resolution: Fixed > kafka-streams to configure internal topics

[jira] [Created] (KAFKA-9379) Flaky Test TopicCommandWithAdminClientTest.testCreateAlterTopicWithRackAware

2020-01-07 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9379: -- Summary: Flaky Test TopicCommandWithAdminClientTest.testCreateAlterTopicWithRackAware Key: KAFKA-9379 URL: https://issues.apache.org/jira/browse/KAFKA-9379

[jira] [Resolved] (KAFKA-9334) Add more unit tests for Materialized class

2019-12-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9334. Fix Version/s: 2.5.0 Resolution: Fixed > Add more unit tests for Materialized class

[jira] [Resolved] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-12-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7994. Resolution: Fixed > Improve Stream-Time for rebalances and restarts >

[jira] [Resolved] (KAFKA-9331) Add option to terminate application when StreamThread(s) die

2019-12-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9331. Resolution: Duplicate > Add option to terminate application when StreamThread(s) die >

[jira] [Created] (KAFKA-9341) Flaky Test TopicCommandWithAdminClientTest#testCreateWithReplicaAssignment

2019-12-29 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9341: -- Summary: Flaky Test TopicCommandWithAdminClientTest#testCreateWithReplicaAssignment Key: KAFKA-9341 URL: https://issues.apache.org/jira/browse/KAFKA-9341

[jira] [Resolved] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter

2019-12-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9321. Resolution: Duplicate > StreamsBuilder table method overwrites the materialized parameter

[jira] [Created] (KAFKA-9302) Allow custom partitioning in foreign-key joins

2019-12-16 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9302: -- Summary: Allow custom partitioning in foreign-key joins Key: KAFKA-9302 URL: https://issues.apache.org/jira/browse/KAFKA-9302 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

2019-12-12 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9295: -- Summary: KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable Key: KAFKA-9295 URL: https://issues.apache.org/jira/browse/KAFKA-9295

[jira] [Created] (KAFKA-9290) Update IQ related JavaDocs

2019-12-11 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9290: -- Summary: Update IQ related JavaDocs Key: KAFKA-9290 URL: https://issues.apache.org/jira/browse/KAFKA-9290 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor

2019-12-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8953. Fix Version/s: 2.5.0 Resolution: Fixed > Consider renaming

[jira] [Created] (KAFKA-9260) Improve Serde "push down" and "wrapping"

2019-12-02 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9260: -- Summary: Improve Serde "push down" and "wrapping" Key: KAFKA-9260 URL: https://issues.apache.org/jira/browse/KAFKA-9260 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

2019-12-02 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9259: -- Summary: suppress() for windowed-Serdes does not work with default serdes Key: KAFKA-9259 URL: https://issues.apache.org/jira/browse/KAFKA-9259 Project: Kafka

[jira] [Created] (KAFKA-9248) Foreign key join does not pickup default serdes and dies with NPE

2019-11-28 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9248: -- Summary: Foreign key join does not pickup default serdes and dies with NPE Key: KAFKA-9248 URL: https://issues.apache.org/jira/browse/KAFKA-9248 Project: Kafka

[jira] [Created] (KAFKA-9238) Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionEnabledByTopicOverride

2019-11-26 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9238: -- Summary: Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionEnabledByTopicOverride Key: KAFKA-9238 URL: https://issues.apache.org/jira/browse/KAFKA-9238

[jira] [Created] (KAFKA-9237) Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabled

2019-11-26 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9237: -- Summary: Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabled Key: KAFKA-9237 URL: https://issues.apache.org/jira/browse/KAFKA-9237 Project:

[jira] [Created] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

2019-11-26 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9234: -- Summary: Consider using @Nullable and @Nonnull annotations Key: KAFKA-9234 URL: https://issues.apache.org/jira/browse/KAFKA-9234 Project: Kafka Issue

[jira] [Resolved] (KAFKA-8960) Move Task determineCommitId in gradle.build to Project Level

2019-11-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8960. Fix Version/s: 2.5.0 Assignee: Bruno Cadonna (was: Rabi Kumar K C)

[jira] [Resolved] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

2019-11-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7996. Resolution: Fixed > KafkaStreams does not pass timeout when closing Producer >

[jira] [Reopened] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

2019-11-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7996: > KafkaStreams does not pass timeout when closing Producer >

[jira] [Reopened] (KAFKA-8403) Suppress needs a Materialized variant

2019-11-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8403: > Suppress needs a Materialized variant > - > >

[jira] [Resolved] (KAFKA-8403) Suppress needs a Materialized variant

2019-11-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8403. Resolution: Fixed > Suppress needs a Materialized variant >

[jira] [Created] (KAFKA-9126) Extend `StreamJoined` to allow more store configs

2019-10-31 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9126: -- Summary: Extend `StreamJoined` to allow more store configs Key: KAFKA-9126 URL: https://issues.apache.org/jira/browse/KAFKA-9126 Project: Kafka Issue

[jira] [Resolved] (KAFKA-9092) Kafka Streams Upgrade Magic v0 does not support record headers

2019-10-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9092. Resolution: Duplicate > Kafka Streams Upgrade Magic v0 does not support record headers >

[jira] [Created] (KAFKA-9108) Flaky Test LogCleanerIntegrationTest#testMarksPartitionsAsOfflineAndPopulatesUncleanableMetrics

2019-10-28 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9108: -- Summary: Flaky Test LogCleanerIntegrationTest#testMarksPartitionsAsOfflineAndPopulatesUncleanableMetrics Key: KAFKA-9108 URL: https://issues.apache.org/jira/browse/KAFKA-9108

[jira] [Resolved] (KAFKA-8914) Setting GROUP_INSTANCE_ID_CONFIG leads to a protobuf error

2019-10-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8914. Resolution: Duplicate Thanks for the follow up [~igmar]. Closing this as duplicate. Btw:

[jira] [Resolved] (KAFKA-6108) Synchronizing on commits and StandbyTasks can be improved

2019-10-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6108. Resolution: Fixed > Synchronizing on commits and StandbyTasks can be improved >

[jira] [Resolved] (KAFKA-4113) Allow KTable bootstrap

2019-10-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4113. Resolution: Invalid Closing this ticket as "invalid" because KTables are populated based

[jira] [Reopened] (KAFKA-9075) Extend documentation for usage of GlobalKTable vs KTable

2019-10-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9075: I think it would actually be good to extend the documentation and explain the semantic

[jira] [Created] (KAFKA-9069) Flaky Test AdminClientIntegrationTest.testCreatePartitions

2019-10-20 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9069: -- Summary: Flaky Test AdminClientIntegrationTest.testCreatePartitions Key: KAFKA-9069 URL: https://issues.apache.org/jira/browse/KAFKA-9069 Project: Kafka

[jira] [Created] (KAFKA-9068) Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)`

2019-10-19 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9068: -- Summary: Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)` Key: KAFKA-9068 URL: https://issues.apache.org/jira/browse/KAFKA-9068 Project: Kafka

[jira] [Reopened] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

2019-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4996: Thanks for pointing out [~ableegoldman] – we should address it – I was assuming that the

[jira] [Resolved] (KAFKA-3534) Deserialize on demand when default time extractor used

2019-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3534. Resolution: Fixed > Deserialize on demand when default time extractor used >

[jira] [Resolved] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

2019-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4996. Resolution: Fixed The corresponding PR was merged. Closing this ticket. > Fix findbugs

[jira] [Resolved] (KAFKA-7424) State stores restoring from changelog topic not the source topic

2019-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7424. Resolution: Fixed [~jhay], [~vvcephei]: I am closing this ticket as it seems to be covered

[jira] [Resolved] (KAFKA-8297) Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics

2019-10-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8297. Resolution: Fixed Closing this ticket because the factory class was deprecated via 

[jira] [Resolved] (KAFKA-9058) Foreign Key Join should not require a queriable store

2019-10-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9058. Fix Version/s: 2.4.0 Resolution: Fixed > Foreign Key Join should not require a

[jira] [Resolved] (KAFKA-9030) Document Instance-level Metrics

2019-10-15 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9030. Fix Version/s: 2.4.0 Resolution: Fixed > Document Instance-level Metrics >

[jira] [Created] (KAFKA-9045) Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-10-15 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9045: -- Summary: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-9045 URL:

[jira] [Resolved] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

2019-10-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8460. Resolution: Duplicate > Flaky Test

[jira] [Created] (KAFKA-9041) Flaky Test LogCleanerIntegrationTest#testIsThreadFailed

2019-10-14 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9041: -- Summary: Flaky Test LogCleanerIntegrationTest#testIsThreadFailed Key: KAFKA-9041 URL: https://issues.apache.org/jira/browse/KAFKA-9041 Project: Kafka

[jira] [Created] (KAFKA-9029) Flaky Test CooperativeStickyAssignorTest.testReassignmentWithRandomSubscriptionsAndChanges

2019-10-11 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9029: -- Summary: Flaky Test CooperativeStickyAssignorTest.testReassignmentWithRandomSubscriptionsAndChanges Key: KAFKA-9029 URL: https://issues.apache.org/jira/browse/KAFKA-9029

[jira] [Reopened] (KAFKA-5566) Instable test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied

2019-10-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5566: [https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/2549/] > Instable test

[jira] [Resolved] (KAFKA-8260) Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-10-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8260. Resolution: Duplicate Closing this as duplicate. > Flaky test >

[jira] [Resolved] (KAFKA-8558) KIP-479 - Add Materialized Overload to KStream#Join

2019-10-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8558. Resolution: Fixed > KIP-479 - Add Materialized Overload to KStream#Join >

[jira] [Created] (KAFKA-8958) Fix Kafka Streams JavaDocs with regard to used Serdes

2019-09-27 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-8958: -- Summary: Fix Kafka Streams JavaDocs with regard to used Serdes Key: KAFKA-8958 URL: https://issues.apache.org/jira/browse/KAFKA-8958 Project: Kafka

[jira] [Created] (KAFKA-8957) Improve docs about `min.isr.` and `acks=all`

2019-09-27 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-8957: -- Summary: Improve docs about `min.isr.` and `acks=all` Key: KAFKA-8957 URL: https://issues.apache.org/jira/browse/KAFKA-8957 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor

2019-09-27 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-8953: -- Summary: Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor Key: KAFKA-8953 URL: https://issues.apache.org/jira/browse/KAFKA-8953 Project:

[jira] [Created] (KAFKA-8944) Compiler Warning

2019-09-25 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-8944: -- Summary: Compiler Warning Key: KAFKA-8944 URL: https://issues.apache.org/jira/browse/KAFKA-8944 Project: Kafka Issue Type: Bug Components:

[jira] [Created] (KAFKA-8927) Remove config `partition.grouper` and interface `PartitionGrouper`

2019-09-19 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-8927: -- Summary: Remove config `partition.grouper` and interface `PartitionGrouper` Key: KAFKA-8927 URL: https://issues.apache.org/jira/browse/KAFKA-8927 Project: Kafka

[jira] [Created] (KAFKA-8909) Flaky Test ReassignPartitionsClusterTest#shouldPerformMultipleReassignmentOperationsOverVariousTopics

2019-09-15 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-8909: -- Summary: Flaky Test ReassignPartitionsClusterTest#shouldPerformMultipleReassignmentOperationsOverVariousTopics Key: KAFKA-8909 URL:

[jira] [Resolved] (KAFKA-4729) Stores for kstream-kstream join cannot be in-memory

2019-09-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4729. Resolution: Duplicate > Stores for kstream-kstream join cannot be in-memory >

[jira] [Reopened] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection

2019-09-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-1534: Assignee: (was: Abhishek Sharma) Failed again: 

[jira] [Created] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS

2019-09-05 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-8878: -- Summary: Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS Key: KAFKA-8878 URL: https://issues.apache.org/jira/browse/KAFKA-8878

[jira] [Reopened] (KAFKA-7940) Flaky Test CustomQuotaCallbackTest#testCustomQuotaCallback

2019-09-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7940: Failed again on `trunk` 

<    1   2   3   4   5   6   7   8   9   10   >