[jira] [Resolved] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

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

[jira] [Created] (KAFKA-9913) TopologyDescription should expose all topic name progrematically

2020-04-23 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9913: -- Summary: TopologyDescription should expose all topic name progrematically Key: KAFKA-9913 URL: https://issues.apache.org/jira/browse/KAFKA-9913 Project: Kafka

[jira] [Created] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

2020-04-20 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9897: -- Summary: Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores Key: KAFKA-9897 URL: https://issues.apache.org/jira/browse/KAFKA-9897

[jira] [Created] (KAFKA-9896) Flaky Test StandbyTaskEOSIntegrationTest#surviveWithOneTaskAsStandby[exactly_once_beta]

2020-04-20 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9896: -- Summary: Flaky Test StandbyTaskEOSIntegrationTest#surviveWithOneTaskAsStandby[exactly_once_beta] Key: KAFKA-9896 URL: https://issues.apache.org/jira/browse/KAFKA-9896

[jira] [Resolved] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore

2020-04-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9243. Resolution: Duplicate Closing is ticket in favor of KAFKA-9290. > Update the javadocs

[jira] [Resolved] (KAFKA-9818) Flaky Test RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler

2020-04-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9818. Fix Version/s: 2.6.0 Resolution: Fixed > Flaky Test >

[jira] [Resolved] (KAFKA-9819) Flaky Test StoreChangelogReaderTest#shouldNotThrowOnUnknownRevokedPartition[0]

2020-04-17 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9819. Fix Version/s: 2.6.0 Resolution: Fixed > Flaky Test

[jira] [Resolved] (KAFKA-9779) Add version 2.5 to streams system tests

2020-04-15 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9779. Fix Version/s: 2.6.0 Resolution: Fixed > Add version 2.5 to streams system tests >

[jira] [Resolved] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

2020-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5676. Resolution: Fixed > MockStreamsMetrics should be in o.a.k.test >

[jira] [Reopened] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

2020-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5676: > MockStreamsMetrics should be in o.a.k.test > -- > >

[jira] [Resolved] (KAFKA-7544) Transient Failure: org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails

2020-04-14 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7544. Resolution: Duplicate Closing this ticket as it links to the older, non-parameterized

[jira] [Resolved] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

2020-04-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9859. Resolution: Not A Problem > kafka-streams-application-reset tool doesn't take into account

[jira] [Resolved] (KAFKA-6910) Ability to specify a default state store type or factory

2020-04-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6910. Resolution: Duplicate > Ability to specify a default state store type or factory >

[jira] [Resolved] (KAFKA-6037) Make Sub-topology Parallelism Tunable

2020-04-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6037. Resolution: Fixed Closing is as "fixed by KAFKA-8611". > Make Sub-topology Parallelism

[jira] [Resolved] (KAFKA-8611) Add KStream#repartition operation

2020-04-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8611. Resolution: Fixed > Add KStream#repartition operation > -

[jira] [Created] (KAFKA-9847) Add config to set default store type

2020-04-09 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9847: -- Summary: Add config to set default store type Key: KAFKA-9847 URL: https://issues.apache.org/jira/browse/KAFKA-9847 Project: Kafka Issue Type:

[jira] [Reopened] (KAFKA-9187) kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2020-04-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9187: This test failed again with a different error message

[jira] [Created] (KAFKA-9832) Extend EOS system tests for EOS-beta

2020-04-07 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9832: -- Summary: Extend EOS system tests for EOS-beta Key: KAFKA-9832 URL: https://issues.apache.org/jira/browse/KAFKA-9832 Project: Kafka Issue Type: Sub-task

[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

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