[jira] [Commented] (KAFKA-7798) Expose embedded client context from KafkaStreams threadMetadata

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

[jira] [Resolved] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7641. Resolution: Fixed Fix Version/s: 2.2.0 > Add `consumer.group.max.size` to cap consum

[jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

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

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758861#comment-16758861 ] Matthias J. Sax commented on KAFKA-7481: [~hachikuji] This is marked as blocker,

[jira] [Commented] (KAFKA-7236) Add --under-min-isr option to describe topics command

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

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

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

[jira] [Commented] (KAFKA-7831) Consumer SubscriptionState missing synchronization

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

[jira] [Created] (KAFKA-7894) When Kafka detached from network; rack isn't logged

Andrey Falko created KAFKA-7894: --- Summary: When Kafka detached from network; rack isn't logged Key: KAFKA-7894 URL: https://issues.apache.org/jira/browse/KAFKA-7894 Project: Kafka Issue Type: B

[jira] [Commented] (KAFKA-7401) Broker fails to start when recovering a segment from before the log start offset

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

[jira] [Created] (KAFKA-7893) Refactor ConsumerBounceTest.scala

Stanislav Kozlovski created KAFKA-7893: -- Summary: Refactor ConsumerBounceTest.scala Key: KAFKA-7893 URL: https://issues.apache.org/jira/browse/KAFKA-7893 Project: Kafka Issue Type: Impro

[jira] [Resolved] (KAFKA-7873) KafkaBasedLog's consumer should always seek to beginning when starting

[ https://issues.apache.org/jira/browse/KAFKA-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7873. Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 2.

[jira] [Commented] (KAFKA-7433) Introduce broker options in TopicCommand to use AdminClient

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

[jira] [Updated] (KAFKA-7320) Provide ability to disable auto topic creation in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7320: --- Fix Version/s: (was: 2.2.0) > Provide ability to disable auto topic creation in KafkaCons

[jira] [Commented] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

[ https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758708#comment-16758708 ] Matthias J. Sax commented on KAFKA-6556: Feature freeze deadline for 2.2 was yest

[jira] [Updated] (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 updated KAFKA-6049: --- Fix Version/s: (was: 2.2.0) > Kafka Streams: Add Cogroup in the DSL > ---

[jira] [Updated] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7026: --- Fix Version/s: (was: 2.2.0) > Sticky assignor could assign a partition to multiple consum

[jira] [Commented] (KAFKA-7873) KafkaBasedLog's consumer should always seek to beginning when starting

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

[jira] [Commented] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758711#comment-16758711 ] Matthias J. Sax commented on KAFKA-4133: Feature freeze deadline for 2.2 was yest

[jira] [Updated] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4133: --- Labels: kip (was: ) > Provide a configuration to control consumer max in-flight fetches > --

[jira] [Updated] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4133: --- Fix Version/s: (was: 2.2.0) > Provide a configuration to control consumer max in-flight f

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

[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758710#comment-16758710 ] Matthias J. Sax commented on KAFKA-6049: Feature freeze deadline for 2.2 was yest

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758705#comment-16758705 ] Matthias J. Sax commented on KAFKA-7026: Feature freeze deadline for 2.2 was yest

[jira] [Commented] (KAFKA-6161) Add default implementation to close() and configure() for Serializer, Deserializer and Serde

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758706#comment-16758706 ] Matthias J. Sax commented on KAFKA-6161: Feature freeze deadline for 2.2 was yest

[jira] [Updated] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

[ https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6556: --- Labels: kip (was: ) > allow to attach callbacks in kafka streams, to be triggered when a win

[jira] [Updated] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

[ https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6556: --- Fix Version/s: (was: 2.2.0) > allow to attach callbacks in kafka streams, to be triggered

[jira] [Commented] (KAFKA-7383) Verify leader epoch in produce requests (KIP-359)

[ https://issues.apache.org/jira/browse/KAFKA-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758703#comment-16758703 ] Matthias J. Sax commented on KAFKA-7383: Feature freeze deadline for 2.2 was yest

[jira] [Commented] (KAFKA-7320) Provide ability to disable auto topic creation in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758702#comment-16758702 ] Matthias J. Sax commented on KAFKA-7320: Feature freeze deadline for 2.2 was yest

[jira] [Updated] (KAFKA-7383) Verify leader epoch in produce requests (KIP-359)

[ https://issues.apache.org/jira/browse/KAFKA-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7383: --- Fix Version/s: (was: 2.2.0) > Verify leader epoch in produce requests (KIP-359) > ---

[jira] [Updated] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

[ https://issues.apache.org/jira/browse/KAFKA-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7471: --- Fix Version/s: (was: 2.2.0) > Multiple Consumer Group Management (Describe, Reset, Delete

[jira] [Commented] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

[ https://issues.apache.org/jira/browse/KAFKA-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758700#comment-16758700 ] Matthias J. Sax commented on KAFKA-7471: Feature freeze deadline for 2.2 was yest

[jira] [Updated] (KAFKA-7440) Use leader epoch in consumer fetch requests

[ https://issues.apache.org/jira/browse/KAFKA-7440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7440: --- Labels: kip (was: ) > Use leader epoch in consumer fetch requests >

[jira] [Updated] (KAFKA-7395) Add fencing to replication protocol (KIP-320)

[ https://issues.apache.org/jira/browse/KAFKA-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7395: --- Labels: kip (was: ) > Add fencing to replication protocol (KIP-320) > --

[jira] [Updated] (KAFKA-6880) Zombie replicas must be fenced

[ https://issues.apache.org/jira/browse/KAFKA-6880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6880: --- Labels: kip (was: needs-kip) > Zombie replicas must be fenced >

[jira] [Assigned] (KAFKA-7885) Streams: TopologyDescription violates equals-hashCode contract.

[ https://issues.apache.org/jira/browse/KAFKA-7885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7885: -- Assignee: Piotr Fras > Streams: TopologyDescription violates equals-hashCode contract.

[jira] [Commented] (KAFKA-7885) Streams: TopologyDescription violates equals-hashCode contract.

[ https://issues.apache.org/jira/browse/KAFKA-7885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758651#comment-16758651 ] Matthias J. Sax commented on KAFKA-7885: [~MonCalamari] Thanks for the patch. I a

[jira] [Commented] (KAFKA-7888) kafka cluster not recovering - Shrinking ISR from 14,13 to 13 (kafka.cluster.Partition) continously

[ https://issues.apache.org/jira/browse/KAFKA-7888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758638#comment-16758638 ] Jun Rao commented on KAFKA-7888: [~kemalerden], from the log, the "Cached zkVersion" log

[jira] [Updated] (KAFKA-7885) Streams: TopologyDescription violates equals-hashCode contract.

[ https://issues.apache.org/jira/browse/KAFKA-7885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7885: --- Priority: Minor (was: Major) > Streams: TopologyDescription violates equals-hashCode contrac

[jira] [Commented] (KAFKA-7828) Execute Trogdor tasks with external commands

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

[jira] [Commented] (KAFKA-7401) Broker fails to start when recovering a segment from before the log start offset

[ https://issues.apache.org/jira/browse/KAFKA-7401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758579#comment-16758579 ] Anna Povzner commented on KAFKA-7401: - I verified that the issue was fixed in 2.0/2.1

[jira] [Commented] (KAFKA-7719) Improve fairness in SocketServer processors

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

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758146#comment-16758146 ] Kemal ERDEN commented on KAFKA-3042: We've hit this on 2.1.0 - I actually raised a ne

[jira] [Updated] (KAFKA-7888) kafka cluster not recovering - Shrinking ISR from 14,13 to 13 (kafka.cluster.Partition) continously

[ https://issues.apache.org/jira/browse/KAFKA-7888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kemal ERDEN updated KAFKA-7888: --- Description: we're seeing the following repeating logs on our kafka cluster from time to time which

[jira] [Commented] (KAFKA-7888) kafka cluster not recovering - Shrinking ISR from 14,13 to 13 (kafka.cluster.Partition) continously

[ https://issues.apache.org/jira/browse/KAFKA-7888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758105#comment-16758105 ] Kemal ERDEN commented on KAFKA-7888: same thing happened yesterday night with increas