[jira] [Commented] (KAFKA-8848) Update system test to use new authorizer

[ https://issues.apache.org/jira/browse/KAFKA-8848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936607#comment-16936607 ] ASF GitHub Bot commented on KAFKA-8848: --- rajinisivaram commented on pull request #7374: KAFKA-8848;

[jira] [Created] (KAFKA-8932) Add tag for TopicConfigErrorCode in CreateTopics response when KIP-482 is merged

Rajini Sivaram created KAFKA-8932: - Summary: Add tag for TopicConfigErrorCode in CreateTopics response when KIP-482 is merged Key: KAFKA-8932 URL: https://issues.apache.org/jira/browse/KAFKA-8932

[jira] [Resolved] (KAFKA-8848) Update system test to use new authorizer

[ https://issues.apache.org/jira/browse/KAFKA-8848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8848. --- Reviewer: Manikumar Resolution: Fixed > Update system test to use new authorizer >

[jira] [Commented] (KAFKA-8907) Return topic configs in CreateTopics response

[ https://issues.apache.org/jira/browse/KAFKA-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936669#comment-16936669 ] ASF GitHub Bot commented on KAFKA-8907: --- rajinisivaram commented on pull request #7380: KAFKA-8907;

[jira] [Created] (KAFKA-8933) An unhandled SSL handshake exception in polling event - needed a retry logic

Remigius created KAFKA-8933: --- Summary: An unhandled SSL handshake exception in polling event - needed a retry logic Key: KAFKA-8933 URL: https://issues.apache.org/jira/browse/KAFKA-8933 Project: Kafka

[jira] [Commented] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

[ https://issues.apache.org/jira/browse/KAFKA-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936642#comment-16936642 ] Suyash Garg commented on KAFKA-8649: Hello [~guozhang], Sorry for the late reply. I didn't use the

[jira] [Updated] (KAFKA-8936) Connect metrics have a chance to disappear on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-8936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Blumenthal updated KAFKA-8936: - Description: We encountered an interesting problem with our connect cluster. At times,

[jira] [Resolved] (KAFKA-6958) Allow to define custom processor names with KStreams DSL

[ https://issues.apache.org/jira/browse/KAFKA-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-6958. Resolution: Fixed Thanks again [~fhussonnois] for your hard work and persistence in seeing this

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936910#comment-16936910 ] Aishwarya Pradeep Kumar commented on KAFKA-8377: {quote}But for some cases, if we force

[jira] [Updated] (KAFKA-6958) Allow to define custom processor names with KStreams DSL

[ https://issues.apache.org/jira/browse/KAFKA-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-6958: --- Fix Version/s: 2.4.0 > Allow to define custom processor names with KStreams DSL >

[jira] [Moved] (KAFKA-8935) Please update zookeeper in the next release

[ https://issues.apache.org/jira/browse/KAFKA-8935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Enrico Olivelli moved ZOOKEEPER-3555 to KAFKA-8935: --- Key: KAFKA-8935 (was: ZOOKEEPER-3555) Workflow:

[jira] [Created] (KAFKA-8936) Connect metrics have a chance to disappear on rebalance

Steven Blumenthal created KAFKA-8936: Summary: Connect metrics have a chance to disappear on rebalance Key: KAFKA-8936 URL: https://issues.apache.org/jira/browse/KAFKA-8936 Project: Kafka

[jira] [Assigned] (KAFKA-8934) Introduce Instance-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-8934: Assignee: Bruno Cadonna > Introduce Instance-level Metrics >

[jira] [Created] (KAFKA-8934) Introduce Instance-level Metrics

Bruno Cadonna created KAFKA-8934: Summary: Introduce Instance-level Metrics Key: KAFKA-8934 URL: https://issues.apache.org/jira/browse/KAFKA-8934 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-8936) Connect metrics have a chance to disappear on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-8936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Blumenthal updated KAFKA-8936: - Priority: Minor (was: Major) > Connect metrics have a chance to disappear on rebalance

[jira] [Commented] (KAFKA-8855) Collect and Expose Client's Name and Version in the Brokers

[ https://issues.apache.org/jira/browse/KAFKA-8855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936969#comment-16936969 ] ASF GitHub Bot commented on KAFKA-8855: --- dajac commented on pull request #7381: KAFKA-8855; Collect

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

[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6049: -- Assignee: Walker Carlson > Kafka Streams: Add Cogroup in the DSL >

[jira] [Updated] (KAFKA-4449) Add Serializer/Deserializer for POJO

[ https://issues.apache.org/jira/browse/KAFKA-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4449: --- Labels: easyfix features needs-kip (was: easyfix features) > Add Serializer/Deserializer

[jira] [Commented] (KAFKA-4449) Add Serializer/Deserializer for POJO

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

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

Guozhang Wang created KAFKA-8940: Summary: Flaky SmokeTestDriverIntegrationTest.shouldWorkWithRebalance Key: KAFKA-8940 URL: https://issues.apache.org/jira/browse/KAFKA-8940 Project: Kafka

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937058#comment-16937058 ] Matthias J. Sax commented on KAFKA-8377: I guess, falling back to the serdes from the config

[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=16937064#comment-16937064 ] Sophie Blee-Goldman commented on KAFKA-7965: Still failing with *Stacktrace* {code:java}

[jira] [Created] (KAFKA-8939) Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup

Sophie Blee-Goldman created KAFKA-8939: -- Summary: Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup Key: KAFKA-8939 URL:

[jira] [Created] (KAFKA-8937) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

Sophie Blee-Goldman created KAFKA-8937: -- Summary: Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-8937 URL:

[jira] [Created] (KAFKA-8938) Connect - Improve Memory Allocations During Struct Validation

Auston McReynolds created KAFKA-8938: Summary: Connect - Improve Memory Allocations During Struct Validation Key: KAFKA-8938 URL: https://issues.apache.org/jira/browse/KAFKA-8938 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-7965: Assignee: (was: Jason Gustafson) Saw another failure in PR builder (2.4) >

[jira] [Commented] (KAFKA-8938) Connect - Improve Memory Allocations During Struct Validation

[ https://issues.apache.org/jira/browse/KAFKA-8938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937070#comment-16937070 ] ASF GitHub Bot commented on KAFKA-8938: --- amcrn commented on pull request #7384: KAFKA-8938 -

[jira] [Issue Comment Deleted] (KAFKA-8938) Connect - Improve Memory Allocations During Struct Validation

[ https://issues.apache.org/jira/browse/KAFKA-8938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Auston McReynolds updated KAFKA-8938: - Comment: was deleted (was: [https://github.com/apache/kafka/pull/7384]) > Connect -

[jira] [Commented] (KAFKA-8880) Augment Consumer.committed(partition) to allow multiple partitions

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

[jira] [Resolved] (KAFKA-8880) Augment Consumer.committed(partition) to allow multiple partitions

[ https://issues.apache.org/jira/browse/KAFKA-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8880. -- Fix Version/s: 2.4.0 Assignee: Guozhang Wang Resolution: Fixed > Augment

[jira] [Commented] (KAFKA-8880) Augment Consumer.committed(partition) to allow multiple partitions

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

[jira] [Commented] (KAFKA-8580) Compute RocksDB Metrics

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

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

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

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937299#comment-16937299 ] ASF GitHub Bot commented on KAFKA-8179: --- ableegoldman commented on pull request #7386: KAFKA-8179:

[jira] [Commented] (KAFKA-8398) NPE when unmapping files after moving log directories using AlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937426#comment-16937426 ] ASF GitHub Bot commented on KAFKA-8398: --- jaikiran commented on pull request #7387: [2.2 branch]

[jira] [Updated] (KAFKA-8933) An unhandled SSL handshake exception in polling event - needed a retry logic

[ https://issues.apache.org/jira/browse/KAFKA-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Remigius updated KAFKA-8933: Issue Type: Bug (was: Wish) > An unhandled SSL handshake exception in polling event - needed a retry

[jira] [Commented] (KAFKA-8880) Augment Consumer.committed(partition) to allow multiple partitions

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

[jira] [Updated] (KAFKA-8100) kafka consumer not refresh metadata for dynamic topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengnan YU updated KAFKA-8100: --- Description: Recently we used flink to consume kafka topics with a regex pattern. It is found that