[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=16819743#comment-16819743 ] Boyang Chen commented on KAFKA-8246: `boolean validChar = (c >= 'a' && c <= 'z') || (c >= '0' && 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:

[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:

[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=16819734#comment-16819734 ] ASF GitHub Bot commented on KAFKA-6647: --- jukkakarvanen commented on pull request #6569: KAFKA-6647

[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=16819732#comment-16819732 ] ASF GitHub Bot commented on KAFKA-6647: --- jukkakarvanen commented on pull request #6569: KAFKA-6647

[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=16819731#comment-16819731 ] ASF GitHub Bot commented on KAFKA-6647: --- jukkakarvanen commented on pull request #6569: KAFKA-6647

[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=16819661#comment-16819661 ] LiWei Wang commented on KAFKA-7563: --- We have meet the same issues.  *Log information:* 1. kstream log：

[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=16819642#comment-16819642 ] ASF GitHub Bot commented on KAFKA-8240: --- mjsax commented on pull request #6589: KAFKA-8240: Fix NPE

[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=16819624#comment-16819624 ] ASF GitHub Bot commented on KAFKA-8237: --- hachikuji commented on pull request #6588: KAFKA-8237

[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] [Created] (KAFKA-8244) Flaky Test GroupAuthorizerIntegrationTest#shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessDuringSend

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

[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=16819620#comment-16819620 ] Matthias J. Sax commented on KAFKA-7965: Also in 1.1 branch: 

[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 >

[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=16819589#comment-16819589 ] ASF GitHub Bot commented on KAFKA-7466: --- cmccabe commented on pull request #6247: KAFKA-7466: Add

[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=16819547#comment-16819547 ] Guozhang Wang commented on KAFKA-4600: -- [~braedon] Please check out this section of the KIP:

[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-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=16819491#comment-16819491 ] ASF GitHub Bot commented on KAFKA-8152: --- hachikuji commented on pull request #6580: KAFKA-8152;

[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=16819476#comment-16819476 ] ASF GitHub Bot commented on KAFKA-7778: --- guozhangwang commented on pull request #6586: KAFKA-7778:

[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=16819432#comment-16819432 ] Bill Bejeck commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/20946/]

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

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

[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

[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

[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=16819258#comment-16819258 ] Richard Yu commented on KAFKA-6520: --- Hello, I've created a KIP for this issue so that we could get some

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

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

[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] [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] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

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

[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=16819164#comment-16819164 ] ASF GitHub Bot commented on KAFKA-7778: --- vvcephei commented on pull request #6586: KAFKA-7778:

[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=16819149#comment-16819149 ] Bill Bejeck commented on KAFKA-8210: cherry-picked to 2.2, 2.1 and 2.0 > Missing link for KStreams

[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] [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] [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=16819096#comment-16819096 ] Bill Bejeck commented on KAFKA-8209: cherry-picked to 2.2, 2.1, 2.0, 1.1 and 1.0 > Wrong 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

[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=16819057#comment-16819057 ] Bill Bejeck commented on KAFKA-8208: cherry-picked to 2.2 and 2.1 > Broken link for out-of-order

[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=16818841#comment-16818841 ] ASF GitHub Bot commented on KAFKA-8241: --- rajinisivaram commented on pull request #6585: KAFKA-8241;

[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

[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] [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] [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=16818807#comment-16818807 ] Andrew Klopper commented on KAFKA-8235: --- Sorry, I am using the version with the suppress operator

[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=16818802#comment-16818802 ] Matthias J. Sax commented on KAFKA-8032:

[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

[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=16818781#comment-16818781 ] Matthias J. Sax commented on KAFKA-7965:

[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=16818779#comment-16818779 ] Matthias J. Sax commented on KAFKA-8078: This time `testInnerOuter` (caching disabled) failed: 

[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=16818775#comment-16818775 ] Matthias J. Sax commented on KAFKA-7965:

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818670#comment-16818670 ] neeraj commented on KAFKA-8207: --- [~mjsax] When is 2.3 release planned? Please feel free to assign me tasks