[jira] [Commented] (KAFKA-8207) StickyPartitionAssignor for KStream

[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818742#comment-16818742 ] Matthias J. Sax commented on KAFKA-8207: There is no timeline yet. Details will b

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818775#comment-16818775 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/blue/organiza

[jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818776#comment-16818776 ] Matthias J. Sax commented on KAFKA-7937: [https://builds.apache.org/blue/organiza

[jira] [Commented] (KAFKA-8078) Flaky Test TableTableJoinIntegrationTest#testInnerInner

[ https://issues.apache.org/jira/browse/KAFKA-8078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818779#comment-16818779 ] Matthias J. Sax commented on KAFKA-8078: This time `testInnerOuter` (caching disa

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818781#comment-16818781 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/blue/organiza

[jira] [Created] (KAFKA-8239) Flaky Test PlaintextConsumerTest#testAutoCommitIntercept

Matthias J. Sax created KAFKA-8239: -- Summary: Flaky Test PlaintextConsumerTest#testAutoCommitIntercept Key: KAFKA-8239 URL: https://issues.apache.org/jira/browse/KAFKA-8239 Project: Kafka Is

[jira] [Commented] (KAFKA-8032) Flaky Test UserQuotaTest#testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818802#comment-16818802 ] Matthias J. Sax commented on KAFKA-8032: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8235) NoSuchElementException when restoring state after a clean shutdown of a Kafka Streams application

[ https://issues.apache.org/jira/browse/KAFKA-8235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818807#comment-16818807 ] Andrew Klopper commented on KAFKA-8235: --- Sorry, I am using the version with the sup

[jira] [Created] (KAFKA-8240) Source.equals() can fail with NPE

Matthias J. Sax created KAFKA-8240: -- Summary: Source.equals() can fail with NPE Key: KAFKA-8240 URL: https://issues.apache.org/jira/browse/KAFKA-8240 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-8241) Dynamic update of keystore fails on listener without truststore

Rajini Sivaram created KAFKA-8241: - Summary: Dynamic update of keystore fails on listener without truststore Key: KAFKA-8241 URL: https://issues.apache.org/jira/browse/KAFKA-8241 Project: Kafka

[jira] [Resolved] (KAFKA-8235) NoSuchElementException when restoring state after a clean shutdown of a Kafka Streams application

[ https://issues.apache.org/jira/browse/KAFKA-8235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8235. Resolution: Invalid Closing this as "invalid" because the reported issue is part of a PR th

[jira] [Commented] (KAFKA-7157) Connect TimestampConverter SMT doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818827#comment-16818827 ] Valeria Vasylieva commented on KAFKA-7157: -- [~rhauch] kindly ask you to look at

[jira] [Commented] (KAFKA-8241) Dynamic update of keystore fails on listener without truststore

[ https://issues.apache.org/jira/browse/KAFKA-8241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818841#comment-16818841 ] ASF GitHub Bot commented on KAFKA-8241: --- rajinisivaram commented on pull request #6

[jira] [Commented] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819057#comment-16819057 ] Bill Bejeck commented on KAFKA-8208: cherry-picked to 2.2 and 2.1 > Broken link for

[jira] [Updated] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8208: --- Fix Version/s: 2.1.0 2.2.0 > Broken link for out-of-order data in KStreams Core Co

[jira] [Commented] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819096#comment-16819096 ] Bill Bejeck commented on KAFKA-8209: cherry-picked to 2.2, 2.1, 2.0, 1.1 and 1.0 > W

[jira] [Updated] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8209: --- Fix Version/s: 1.0.0 1.1.0 2.0.0 2.1.0

[jira] [Updated] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8210: --- Fix Version/s: 2.1.0 2.2.0 > Missing link for KStreams in Streams DSL docs > -

[jira] [Commented] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819149#comment-16819149 ] Bill Bejeck commented on KAFKA-8210: cherry-picked to 2.2, 2.1 and 2.0 > Missing lin

[jira] [Commented] (KAFKA-7778) Add KTable.suppress to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819164#comment-16819164 ] ASF GitHub Bot commented on KAFKA-7778: --- vvcephei commented on pull request #6586:

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819185#comment-16819185 ] Bill Bejeck commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-jdk8-sca

[jira] [Resolved] (KAFKA-7875) Add KStream#flatTransformValues

[ https://issues.apache.org/jira/browse/KAFKA-7875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7875. Resolution: Fixed > Add KStream#flatTransformValues > --- > >

[jira] [Updated] (KAFKA-7875) Add KStream#flatTransformValues

[ https://issues.apache.org/jira/browse/KAFKA-7875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7875: --- Fix Version/s: 2.3.0 > Add KStream#flatTransformValues > --- > >

[jira] [Commented] (KAFKA-7875) Add KStream#flatTransformValues

[ https://issues.apache.org/jira/browse/KAFKA-7875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819197#comment-16819197 ] ASF GitHub Bot commented on KAFKA-7875: --- bbejeck commented on pull request #6424: K

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819258#comment-16819258 ] Richard Yu commented on KAFKA-6520: --- Hello, I've created a KIP for this issue so that w

[jira] [Created] (KAFKA-8242) Exception in ReplicaFetcher blocks replication of all other partitions

Nevins Bartolomeo created KAFKA-8242: Summary: Exception in ReplicaFetcher blocks replication of all other partitions Key: KAFKA-8242 URL: https://issues.apache.org/jira/browse/KAFKA-8242 Project:

[jira] [Updated] (KAFKA-8242) Exception in ReplicaFetcher blocks replication of all other partitions

[ https://issues.apache.org/jira/browse/KAFKA-8242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nevins Bartolomeo updated KAFKA-8242: - Component/s: replication > Exception in ReplicaFetcher blocks replication of all other pa

[jira] [Commented] (KAFKA-7565) NPE in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819330#comment-16819330 ] Jose Armando Garcia Sancio commented on KAFKA-7565: --- It is likely that

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819348#comment-16819348 ] Richard Yu commented on KAFKA-6520: --- Oh, and [~milindjain] Do you mind if you take this

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819432#comment-16819432 ] Bill Bejeck commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-jdk8-sca

[jira] [Commented] (KAFKA-7778) Add KTable.suppress to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819476#comment-16819476 ] ASF GitHub Bot commented on KAFKA-7778: --- guozhangwang commented on pull request #65

[jira] [Commented] (KAFKA-8152) Offline partition state not propagated by controller

[ https://issues.apache.org/jira/browse/KAFKA-8152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819491#comment-16819491 ] ASF GitHub Bot commented on KAFKA-8152: --- hachikuji commented on pull request #6580:

[jira] [Created] (KAFKA-8243) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated

Matthias J. Sax created KAFKA-8243: -- Summary: Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated Key: KAFKA-8243 URL: https://issues.apache.org/jira/browse/KAFKA-8243

[jira] [Commented] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819547#comment-16819547 ] Guozhang Wang commented on KAFKA-4600: -- [~braedon] Please check out this section of

[jira] [Commented] (KAFKA-7466) Implement KIP-339: Create a new IncrementalAlterConfigs API

[ https://issues.apache.org/jira/browse/KAFKA-7466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819589#comment-16819589 ] ASF GitHub Bot commented on KAFKA-7466: --- cmccabe commented on pull request #6247: K

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819620#comment-16819620 ] Matthias J. Sax commented on KAFKA-7965: Also in 1.1 branch:  [https://builds.apa

[jira] [Updated] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7965: --- Affects Version/s: 1.1.1 > Flaky Test > ConsumerBounceTest#testRollingBrokerRestartsWithSmal

[jira] [Created] (KAFKA-8244) Flaky Test GroupAuthorizerIntegrationTest#shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessDuringSend

Matthias J. Sax created KAFKA-8244: -- Summary: Flaky Test GroupAuthorizerIntegrationTest#shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessDuringSend Key: KAFKA-8244 URL: https://issues.apache

[jira] [Created] (KAFKA-8245) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdAllGroups

Matthias J. Sax created KAFKA-8245: -- Summary: Flaky Test DeleteConsumerGroupsTest#testDeleteCmdAllGroups Key: KAFKA-8245 URL: https://issues.apache.org/jira/browse/KAFKA-8245 Project: Kafka

[jira] [Commented] (KAFKA-8032) Flaky Test UserQuotaTest#testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819622#comment-16819622 ] Matthias J. Sax commented on KAFKA-8032: Failed again:  [https://builds.apache.or

[jira] [Commented] (KAFKA-8113) Flaky Test ListOffsetsRequestTest#testResponseIncludesLeaderEpoch

[ https://issues.apache.org/jira/browse/KAFKA-8113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819623#comment-16819623 ] Matthias J. Sax commented on KAFKA-8113: Failed again:  [https://builds.apache.or

[jira] [Commented] (KAFKA-8237) Untangle TopicDeletionManager and add test cases

[ https://issues.apache.org/jira/browse/KAFKA-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819624#comment-16819624 ] ASF GitHub Bot commented on KAFKA-8237: --- hachikuji commented on pull request #6588:

[jira] [Assigned] (KAFKA-8240) Source.equals() can fail with NPE

[ https://issues.apache.org/jira/browse/KAFKA-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8240: -- Assignee: Matthias J. Sax > Source.equals() can fail with NPE > --

[jira] [Commented] (KAFKA-8240) Source.equals() can fail with NPE

[ https://issues.apache.org/jira/browse/KAFKA-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819642#comment-16819642 ] ASF GitHub Bot commented on KAFKA-8240: --- mjsax commented on pull request #6589: KAF

[jira] [Commented] (KAFKA-7563) Single broker sends incorrect metadata for topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-7563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819661#comment-16819661 ] LiWei Wang commented on KAFKA-7563: --- We have meet the same issues.  *Log information:*

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819731#comment-16819731 ] ASF GitHub Bot commented on KAFKA-6647: --- jukkakarvanen commented on pull request #6

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819732#comment-16819732 ] ASF GitHub Bot commented on KAFKA-6647: --- jukkakarvanen commented on pull request #6

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819734#comment-16819734 ] ASF GitHub Bot commented on KAFKA-6647: --- jukkakarvanen commented on pull request #6

[jira] [Resolved] (KAFKA-7466) Implement KIP-339: Create a new IncrementalAlterConfigs API

[ https://issues.apache.org/jira/browse/KAFKA-7466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7466. -- Resolution: Fixed Reviewer: Colin P. McCabe Fix Version/s: 2.3.0 > Implement KIP-339: C

[jira] [Created] (KAFKA-8246) refactor topic/group instance id validation condition

Boyang Chen created KAFKA-8246: -- Summary: refactor topic/group instance id validation condition Key: KAFKA-8246 URL: https://issues.apache.org/jira/browse/KAFKA-8246 Project: Kafka Issue Type: I

[jira] [Commented] (KAFKA-8246) refactor topic/group instance id validation condition

[ https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819743#comment-16819743 ] Boyang Chen commented on KAFKA-8246: `boolean validChar = (c >= 'a' && c <= 'z') || (

[jira] [Commented] (KAFKA-8032) Flaky Test UserQuotaTest#testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819767#comment-16819767 ] Manikumar commented on KAFKA-8032: -- [~mjsax] Sorry for the delay. Will take a look next