[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: - Attachment: (was: AssignmentInfo.java) > Reduce assignment data size to improve kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-6123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu reassigned KAFKA-6123: --- Assignee: Kevin Lu > Give client MetricsReporter auto-generated client.id >

[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=16539578#comment-16539578 ] Guozhang Wang commented on KAFKA-7144: -- Hi [~wushujames], how many threads did you configure with

[jira] [Commented] (KAFKA-6976) Kafka Streams instances going in to DEAD state

[ https://issues.apache.org/jira/browse/KAFKA-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539565#comment-16539565 ] Ashish Surana commented on KAFKA-6976: -- Created below ticket to address this issue the right way:

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

Ashish Surana created KAFKA-7149: Summary: Reduce assignment data size to improve kafka streams scalability Key: KAFKA-7149 URL: https://issues.apache.org/jira/browse/KAFKA-7149 Project: Kafka

[jira] [Updated] (KAFKA-7148) Kafka load log very slow after goes down with outOfMemoryError

[ https://issues.apache.org/jira/browse/KAFKA-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wang updated KAFKA-7148: Description: two questions 1、is there any idea to avoid the IOException: Map failed, or is there any limit in vm

[jira] [Created] (KAFKA-7148) Kafka load log very slow after goes down with outOfMemoryError

wang created KAFKA-7148: --- Summary: Kafka load log very slow after goes down with outOfMemoryError Key: KAFKA-7148 URL: https://issues.apache.org/jira/browse/KAFKA-7148 Project: Kafka Issue Type: Bug

[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] [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] [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] [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] [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: --- Summary: Cannot use KafkaConsumer with Kotlin coroutines due to various issues (was: Cannot use

[jira] [Updated] (KAFKA-3438) Rack Aware Replica Reassignment should warn of overloaded brokers

[ https://issues.apache.org/jira/browse/KAFKA-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-3438: --- Fix Version/s: 2.1.0 > Rack Aware Replica Reassignment should warn of overloaded brokers >

[jira] [Updated] (KAFKA-3999) Consumer bytes-fetched metric uses decompressed message size (KIP-264)

[ https://issues.apache.org/jira/browse/KAFKA-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-3999: --- Labels: kip (was: ) > Consumer bytes-fetched metric uses decompressed message size

[jira] [Updated] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-7037: --- Fix Version/s: 2.1.0 > delete topic command replaces '+' from the topic name which leads

[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=16539373#comment-16539373 ] James Cheng commented on KAFKA-7141: I think it's a little odd that kafka-consumer-groups doesn't

[jira] [Resolved] (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 ] Vahid Hashemian resolved KAFKA-7141. Resolution: Not A Problem > kafka-consumer-group doesn't describe existing group >

[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=16539282#comment-16539282 ] Vahid Hashemian commented on KAFKA-7141: [~kioria] thanks for the detailed info. What you're

[jira] [Updated] (KAFKA-7147) ReassignPartitionsCommand should be able to connect to broker over SSL

[ https://issues.apache.org/jira/browse/KAFKA-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7147: Description: Currently both ReassignPartitionsCommand and LogDirsCommand instantiates AdminClient using

[jira] [Commented] (KAFKA-7121) Intermittently, Connectors fail to assign tasks and keep retrying every second forever.

[ https://issues.apache.org/jira/browse/KAFKA-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539264#comment-16539264 ] Gwen Shapira commented on KAFKA-7121: - Oh, sorry [~yuzhih...@gmail.com], I forgot to update: We used

[jira] [Commented] (KAFKA-7147) ReassignPartitionsCommand should be able to connect to broker over SSL

[ https://issues.apache.org/jira/browse/KAFKA-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539258#comment-16539258 ] ASF GitHub Bot commented on KAFKA-7147: --- lindong28 opened a new pull request #5355: KAFKA-7147;

[jira] [Created] (KAFKA-7147) ReassignPartitionsCommand should be able to connect to broker over SSL

Dong Lin created KAFKA-7147: --- Summary: ReassignPartitionsCommand should be able to connect to broker over SSL Key: KAFKA-7147 URL: https://issues.apache.org/jira/browse/KAFKA-7147 Project: Kafka

[jira] [Commented] (KAFKA-7146) Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups

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

[jira] [Updated] (KAFKA-7146) Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-7146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan updated KAFKA-7146: --- Description: Subtask of KAFKA-6788. Group consumer requests for describeConsumerGroups().  

[jira] [Assigned] (KAFKA-7146) Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-7146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan reassigned KAFKA-7146: -- Assignee: Yishun Guan > Grouping consumer requests per consumer coordinator in admin client

[jira] [Updated] (KAFKA-7146) Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-7146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yishun Guan updated KAFKA-7146: --- Description: Subtask of KAFKA-6788. Group consumer requests for describeConsumerGroups().  

[jira] [Created] (KAFKA-7146) Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups

Yishun Guan created KAFKA-7146: -- Summary: Grouping consumer requests per consumer coordinator in admin client in describeConsumerGroups Key: KAFKA-7146 URL: https://issues.apache.org/jira/browse/KAFKA-7146

[jira] [Commented] (KAFKA-5638) Inconsistency in consumer group related ACLs

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

[jira] [Resolved] (KAFKA-7080) WindowStoreBuilder incorrectly initializes CachingWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-7080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7080. - Resolution: Fixed Fixed in https://github.com/apache/kafka/pull/5257 > WindowStoreBuilder

[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=16538861#comment-16538861 ] Bohdana Panchenko commented on KAFKA-7141: -- [~vahid], i have updates from my side.  First:  i

[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=16538861#comment-16538861 ] Bohdana Panchenko edited comment on KAFKA-7141 at 7/10/18 4:06 PM: ---

[jira] [Commented] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

[ https://issues.apache.org/jira/browse/KAFKA-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538687#comment-16538687 ] Viktor Somogyi commented on KAFKA-1774: --- [~abiletskyi] do you still work on this? We have a spike

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 7/10/18 12:16 PM: - +1 from me was

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Description: Currently connector tests make heavy use of mock (easymock, power mock). This may hide the real

[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=16538400#comment-16538400 ] Bohdana Panchenko commented on KAFKA-7141: -- Steps to reproduce the issue: I am using Windows and

[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=16538255#comment-16538255 ] Bohdana Panchenko commented on KAFKA-7141: -- [~vahid], let me check and i will be back >