[jira] [Commented] (KAFKA-5319) Add a tool to make cluster replica and leader balance

[ https://issues.apache.org/jira/browse/KAFKA-5319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541185#comment-16541185 ] Carl Haferd commented on KAFKA-5319: Is there active development ongoing for this ticket? We have

[jira] [Commented] (KAFKA-6123) Give client MetricsReporter auto-generated client.id

[ https://issues.apache.org/jira/browse/KAFKA-6123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540996#comment-16540996 ] Kevin Lu commented on KAFKA-6123: - [~cmccabe] Since you worked on the mentioned issue, what are your

[jira] [Commented] (KAFKA-6962) DescribeConfigsRequest Schema documentation is wrong/missing detail

[ https://issues.apache.org/jira/browse/KAFKA-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540848#comment-16540848 ] Sean Policarpio commented on KAFKA-6962: Ummm, anyone able to review this? My patch has now ended

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540741#comment-16540741 ] Yu Yang commented on KAFKA-5886: [~ashsskum]   The pull request 

[jira] [Comment Edited] (KAFKA-7126) Reduce number of rebalance period for large consumer groups after a topic is created

[ https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540687#comment-16540687 ] Dong Lin edited comment on KAFKA-7126 at 7/11/18 9:31 PM: -- Suppose there is no

[jira] [Commented] (KAFKA-7126) Reduce number of rebalance period for large consumer groups after a topic is created

[ https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540687#comment-16540687 ] Dong Lin commented on KAFKA-7126: - Suppose there is no error such as network disconnection or timeout,

[jira] [Updated] (KAFKA-7147) Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file

[ https://issues.apache.org/jira/browse/KAFKA-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7147: Summary: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file

[jira] [Created] (KAFKA-7152) replica should be in-sync if its LEO equals leader's LEO

Dong Lin created KAFKA-7152: --- Summary: replica should be in-sync if its LEO equals leader's LEO Key: KAFKA-7152 URL: https://issues.apache.org/jira/browse/KAFKA-7152 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7151) Broker running out of disk space may result in state where unclean leader election is required

Anna Povzner created KAFKA-7151: --- Summary: Broker running out of disk space may result in state where unclean leader election is required Key: KAFKA-7151 URL: https://issues.apache.org/jira/browse/KAFKA-7151

[jira] [Updated] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7149: --- Component/s: streams > Reduce assignment data size to improve kafka streams scalability >

[jira] [Created] (KAFKA-7150) Error in processing fetched data for one partition may stop follower fetching other partitions

Anna Povzner created KAFKA-7150: --- Summary: Error in processing fetched data for one partition may stop follower fetching other partitions Key: KAFKA-7150 URL: https://issues.apache.org/jira/browse/KAFKA-7150

[jira] [Updated] (KAFKA-7143) Cannot use KafkaConsumer with Kotlin coroutines due to various issues

[ https://issues.apache.org/jira/browse/KAFKA-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-7143: --- Description: I am using a new KafkaConsumer via Kotlin. My application makes use of Kotlin

[jira] [Commented] (KAFKA-7145) Consumer thread getting stuck in hasNext() method

[ https://issues.apache.org/jira/browse/KAFKA-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539982#comment-16539982 ] Andras Beni commented on KAFKA-7145: [~lovenishgoyal], as I can see you are using the so called 'old

[jira] [Updated] (KAFKA-7139) Support to exclude the internal topics in kafka-topics.sh command

[ https://issues.apache.org/jira/browse/KAFKA-7139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-7139: -- Description: _{color:#33}Usually we have no interest in internal topics when using the 

[jira] [Updated] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Surana updated KAFKA-7149: - Description: We observed that when we have high number of partitions, instances or

[jira] [Updated] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Surana updated KAFKA-7149: - Description: We observed that when we have high number of partitions, instances or

[jira] [Comment Edited] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539596#comment-16539596 ] Ashish Surana edited comment on KAFKA-7149 at 7/11/18 6:34 AM: --- Made the

[jira] [Comment Edited] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539596#comment-16539596 ] Ashish Surana edited comment on KAFKA-7149 at 7/11/18 6:33 AM: --- Made the

[jira] [Comment Edited] (KAFKA-7141) kafka-consumer-group doesn't describe existing group

[ https://issues.apache.org/jira/browse/KAFKA-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539619#comment-16539619 ] huxihx edited comment on KAFKA-7141 at 7/11/18 6:24 AM: [~wushujames] Agreed.

[jira] [Comment Edited] (KAFKA-7141) kafka-consumer-group doesn't describe existing group

[ https://issues.apache.org/jira/browse/KAFKA-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539619#comment-16539619 ] huxihx edited comment on KAFKA-7141 at 7/11/18 6:23 AM: [~wushujames] Agreed.

[jira] [Commented] (KAFKA-7141) kafka-consumer-group doesn't describe existing group

[ https://issues.apache.org/jira/browse/KAFKA-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539619#comment-16539619 ] huxihx commented on KAFKA-7141: --- [~wushujames] Agreed. This makes no sense that whether committing offsets

[jira] [Commented] (KAFKA-7141) kafka-consumer-group doesn't describe existing group

[ https://issues.apache.org/jira/browse/KAFKA-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539616#comment-16539616 ] ASF GitHub Bot commented on KAFKA-7141: --- huxihx opened a new pull request #5356: KAFKA-7141:

[jira] [Reopened] (KAFKA-7141) kafka-consumer-group doesn't describe existing group

[ https://issues.apache.org/jira/browse/KAFKA-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reopened KAFKA-7141: --- Assignee: huxihx > kafka-consumer-group doesn't describe existing group >

[jira] [Commented] (KAFKA-7144) Kafka Streams doesn't properly balance partition assignment

[ https://issues.apache.org/jira/browse/KAFKA-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539598#comment-16539598 ] James Cheng commented on KAFKA-7144: The attached repro java file has all the code. I didn’t specify