[jira] [Commented] (KAFKA-5431) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

[ https://issues.apache.org/jira/browse/KAFKA-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722728#comment-16722728 ] Swathi Mocharla commented on KAFKA-5431: hi [~huxi_2b], we are currently on .11.0.0 and are

[jira] [Commented] (KAFKA-7728) Add JoinReason to the join group request for better rebalance handling

[ https://issues.apache.org/jira/browse/KAFKA-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722715#comment-16722715 ] Boyang Chen commented on KAFKA-7728: [~guozhang] [~mjsax] [~hachikuji] [~enether] Do you have time to

[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=16722691#comment-16722691 ] Justin Jack commented on KAFKA-7641: We are already working on the KIP and it is currently being

[jira] [Updated] (KAFKA-7742) DelegationTokenCache#hmacIdCache entry is not cleared when a token is removed using removeToken(String tokenId) API.

[ https://issues.apache.org/jira/browse/KAFKA-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-7742: -- Description: DelegationTokenCache#hmacIdCache entry is not cleared when a token is removed

[jira] [Created] (KAFKA-7742) DelegationTokenCache#hmacIdCache entry is not cleared when a token is removed using removeToken(String tokenId) API.

Satish Duggana created KAFKA-7742: - Summary: DelegationTokenCache#hmacIdCache entry is not cleared when a token is removed using removeToken(String tokenId) API. Key: KAFKA-7742 URL:

[jira] [Commented] (KAFKA-7432) API Method on Kafka Streams for processing chunks/batches of data

[ https://issues.apache.org/jira/browse/KAFKA-7432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722635#comment-16722635 ] Richard Yu commented on KAFKA-7432: --- Hi, just want to point out something here. What Kafka currently

[jira] [Comment Edited] (KAFKA-7432) API Method on Kafka Streams for processing chunks/batches of data

[ https://issues.apache.org/jira/browse/KAFKA-7432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722635#comment-16722635 ] Richard Yu edited comment on KAFKA-7432 at 12/17/18 1:59 AM: - Hi, just want

[jira] [Commented] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722624#comment-16722624 ] Guozhang Wang commented on KAFKA-7243: -- [~johnma] are you still working on this ticket? If not could

[jira] [Commented] (KAFKA-6820) Improve on StreamsMetrics Public APIs

[ https://issues.apache.org/jira/browse/KAFKA-6820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722623#comment-16722623 ] Guozhang Wang commented on KAFKA-6820: -- [~NIzhikov] Yes this ticket is still on, and actually it is

[jira] [Commented] (KAFKA-6819) Refactor build-in StreamsMetrics internal implementations

[ https://issues.apache.org/jira/browse/KAFKA-6819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722619#comment-16722619 ] Guozhang Wang commented on KAFKA-6819: -- Please see my other comment on KAFKA-6820. > Refactor

[jira] [Commented] (KAFKA-7176) State store metrics for migrated tasks are not removed

[ https://issues.apache.org/jira/browse/KAFKA-7176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722610#comment-16722610 ] Guozhang Wang commented on KAFKA-7176: -- I've looked into trunk again and I believe it's been fixed

[jira] [Commented] (KAFKA-7293) Merge followed by groupByKey/join might violate co-partioning

[ https://issues.apache.org/jira/browse/KAFKA-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722600#comment-16722600 ] Richard Yu commented on KAFKA-7293: --- It probably also would be a good idea to define the behavior that

[jira] [Commented] (KAFKA-2758) Improve Offset Commit Behavior

[ https://issues.apache.org/jira/browse/KAFKA-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722593#comment-16722593 ] Richard Yu commented on KAFKA-2758: --- I just want to say that this issue might no longer be relevant. It

[jira] [Commented] (KAFKA-7234) Allow auto leader rebalance during partition reassignment

[ https://issues.apache.org/jira/browse/KAFKA-7234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722598#comment-16722598 ] Richard Yu commented on KAFKA-7234: --- This might be a corner case, but if several nodes are brought into

[jira] [Commented] (KAFKA-7703) KafkaConsumer.position may return a wrong offset after "seekToEnd" is called

[ https://issues.apache.org/jira/browse/KAFKA-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722591#comment-16722591 ] Dongjoon Hyun commented on KAFKA-7703: -- Hi, All. Is there any update for this issue? >

[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=16722566#comment-16722566 ] sacha barber commented on KAFKA-6647: - I would also like to add this seems to be caused by the 

[jira] [Created] (KAFKA-7741) Bad dependency via SBT

sacha barber created KAFKA-7741: --- Summary: Bad dependency via SBT Key: KAFKA-7741 URL: https://issues.apache.org/jira/browse/KAFKA-7741 Project: Kafka Issue Type: Bug Components: