[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007928#comment-17007928 ] Omkar Mestry commented on KAFKA-9259: - [~vvcephei] I went through code and found that in 

[jira] [Commented] (KAFKA-7737) Consolidate InitProducerId API

[ https://issues.apache.org/jira/browse/KAFKA-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007878#comment-17007878 ] Jason Gustafson commented on KAFKA-7737: [~viktorsomogyi] Do you mind if I pick this up? I have a

[jira] [Commented] (KAFKA-9330) Calling AdminClient.close in the AdminClient completion callback causes deadlock

[ https://issues.apache.org/jira/browse/KAFKA-9330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007863#comment-17007863 ] ASF GitHub Bot commented on KAFKA-9330: --- soondenana commented on pull request #7866: KAFKA-9330:

[jira] [Commented] (KAFKA-9330) Calling AdminClient.close in the AdminClient completion callback causes deadlock

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

[jira] [Commented] (KAFKA-8770) Either switch to or add an option for emit-on-change

[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007860#comment-17007860 ] Richard Yu commented on KAFKA-8770: --- [~vvcephei] It seems that loading all the prior results would be

[jira] [Commented] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1.

[ https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007853#comment-17007853 ] Boyang Chen commented on KAFKA-9335: By applying your example, I could successfully reproduce the

[jira] [Resolved] (KAFKA-9293) NPE in DumpLogSegments with --offsets-decoder

[ https://issues.apache.org/jira/browse/KAFKA-9293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9293. Fix Version/s: 2.4.1 Resolution: Fixed > NPE in DumpLogSegments with

[jira] [Commented] (KAFKA-9293) NPE in DumpLogSegments with --offsets-decoder

[ https://issues.apache.org/jira/browse/KAFKA-9293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007762#comment-17007762 ] ASF GitHub Bot commented on KAFKA-9293: --- hachikuji commented on pull request #7820: KAFKA-9293; Fix

[jira] [Commented] (KAFKA-9210) kafka stream loss data

[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007756#comment-17007756 ] Sophie Blee-Goldman commented on KAFKA-9210: Great! I think we can close this ticket as a

[jira] [Commented] (KAFKA-9364) Fix misleading consumer logs on throttling

[ https://issues.apache.org/jira/browse/KAFKA-9364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007717#comment-17007717 ] ASF GitHub Bot commented on KAFKA-9364: --- cmccabe commented on pull request #7894: KAFKA-9364: Fix

[jira] [Created] (KAFKA-9364) Fix misleading consumer logs on throttling

Colin McCabe created KAFKA-9364: --- Summary: Fix misleading consumer logs on throttling Key: KAFKA-9364 URL: https://issues.apache.org/jira/browse/KAFKA-9364 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007697#comment-17007697 ] Matthias J. Sax commented on KAFKA-7994: Feel free to update the ticket – but we should create

[jira] [Updated] (KAFKA-9352) unbalanced assignment of topic-partition to tasks

[ https://issues.apache.org/jira/browse/KAFKA-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning Zhang updated KAFKA-9352: -- Issue Type: New Feature (was: Improvement) > unbalanced assignment of topic-partition to tasks >

[jira] [Commented] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007666#comment-17007666 ] Guozhang Wang commented on KAFKA-9312: -- I think it is indeed an issue that we overlooked. As

[jira] [Commented] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007664#comment-17007664 ] Jonathan Santilli commented on KAFKA-9312: -- Checking a little bit further seems like yes, it

[jira] [Comment Edited] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 5:39 PM: -- After

[jira] [Commented] (KAFKA-9340) Potential race condition in AbstractConfig

[ https://issues.apache.org/jira/browse/KAFKA-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007646#comment-17007646 ] M. Manna commented on KAFKA-9340: - Perhaps someone else can confirm this too?  I am not sure why

[jira] [Comment Edited] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006983#comment-17006983 ] Boyang Chen edited comment on KAFKA-9355 at 1/3/20 5:34 PM: Thanks for the

[jira] [Commented] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1.

[ https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007641#comment-17007641 ] Boyang Chen commented on KAFKA-9335: Sounds good, I will try to reproduce it today. >

[jira] [Commented] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007635#comment-17007635 ] Lucas Bradstreet commented on KAFKA-9312: - [~pachilo] are you saying that in the existing code,

[jira] [Commented] (KAFKA-9363) Admin Script "kafka-topics" doesn't confirm on successful creation

[ https://issues.apache.org/jira/browse/KAFKA-9363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007630#comment-17007630 ] ASF GitHub Bot commented on KAFKA-9363: --- mmanna-sapfgl commented on pull request #7893: KAFKA-9363

[jira] [Created] (KAFKA-9363) Admin Script "kafka-topics" doesn't confirm on successful creation

M. Manna created KAFKA-9363: --- Summary: Admin Script "kafka-topics" doesn't confirm on successful creation Key: KAFKA-9363 URL: https://issues.apache.org/jira/browse/KAFKA-9363 Project: Kafka

[jira] [Commented] (KAFKA-9362) Missing GC logs when running Kafka with Java 11 with OpenJ9 VM

[ https://issues.apache.org/jira/browse/KAFKA-9362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007525#comment-17007525 ] Alexandre Vermeerbergen commented on KAFKA-9362: My bad, the new version of the lines

[jira] [Created] (KAFKA-9362) Missing GC logs when running Kafka with Java 11 with OpenJ9 VM

Alexandre Vermeerbergen created KAFKA-9362: -- Summary: Missing GC logs when running Kafka with Java 11 with OpenJ9 VM Key: KAFKA-9362 URL: https://issues.apache.org/jira/browse/KAFKA-9362

[jira] [Commented] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1.

[ https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007394#comment-17007394 ] Nitay Kufert commented on KAFKA-9335: - 1. Yes 2. I tried with 12 but I believe it wouldn't matter 3.

[jira] [Comment Edited] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:19 AM: -- After

[jira] [Comment Edited] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:18 AM: -- After

[jira] [Comment Edited] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:18 AM: -- After

[jira] [Comment Edited] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:18 AM: -- After

[jira] [Commented] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli commented on KAFKA-9312: -- After interacting with the code to solve the issue