[jira] [Updated] (KAFKA-9466) Add documentation for new stream EOS change

2020-01-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9466: --- Component/s: streams docs > Add documentation for new stream EOS change >

[jira] [Assigned] (KAFKA-9464) Close the producer in completeShutdown

2020-01-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9464: -- Assignee: Ted Yu > Close the producer in completeShutdown >

[jira] [Commented] (KAFKA-9465) Enclose consumer call with catching InvalidOffsetException

2020-01-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021807#comment-17021807 ] Matthias J. Sax commented on KAFKA-9465: Add you to the list of contributors – you can now self

[jira] [Assigned] (KAFKA-9465) Enclose consumer call with catching InvalidOffsetException

2020-01-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9465: -- Assignee: Ted Yu > Enclose consumer call with catching InvalidOffsetException >

[jira] [Commented] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

2020-01-22 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021795#comment-17021795 ] Jun Rao commented on KAFKA-8532: [~lbdai3190] :  To verify this, I wrote the following short program. I

[jira] [Updated] (KAFKA-9468) config.storage.topic partition count issue is hard to debug

2020-01-22 Thread Evelyn Bayes (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evelyn Bayes updated KAFKA-9468: Description: When you run connect distributed with 2 or more workers and config.storage.topic has

[jira] [Created] (KAFKA-9468) config.storage.topic partition count issue is hard to debug

2020-01-22 Thread Evelyn Bayes (Jira)
Evelyn Bayes created KAFKA-9468: --- Summary: config.storage.topic partition count issue is hard to debug Key: KAFKA-9468 URL: https://issues.apache.org/jira/browse/KAFKA-9468 Project: Kafka

[jira] [Commented] (KAFKA-9467) Multiple wallclock punctuators may be scheduled after a rebalance

2020-01-22 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021696#comment-17021696 ] Sophie Blee-Goldman commented on KAFKA-9467: Obviously option 3 is a lot more work and may

[jira] [Created] (KAFKA-9467) Multiple wallclock punctuators may be scheduled after a rebalance

2020-01-22 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9467: -- Summary: Multiple wallclock punctuators may be scheduled after a rebalance Key: KAFKA-9467 URL: https://issues.apache.org/jira/browse/KAFKA-9467 Project:

[jira] [Resolved] (KAFKA-9082) Move ConfigCommand to use KafkaAdminClient APIs

2020-01-22 Thread Brian Byrne (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Byrne resolved KAFKA-9082. Resolution: Duplicate The outstanding work to be completed is now identical to KAFKA-7740. Marking

[jira] [Updated] (KAFKA-9082) Move ConfigCommand to use KafkaAdminClient APIs

2020-01-22 Thread Brian Byrne (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Byrne updated KAFKA-9082: --- Fix Version/s: 2.5.0 > Move ConfigCommand to use KafkaAdminClient APIs >

[jira] [Updated] (KAFKA-9466) Add documentation for new stream EOS change

2020-01-22 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9466: --- Description: We shall fill in more details when we actually reach this stage. > Add documentation

[jira] [Created] (KAFKA-9466) Add documentation for new stream EOS change

2020-01-22 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9466: -- Summary: Add documentation for new stream EOS change Key: KAFKA-9466 URL: https://issues.apache.org/jira/browse/KAFKA-9466 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-7740) Kafka Admin Client should be able to manage user/client configurations for users and clients

2020-01-22 Thread Brian Byrne (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Byrne updated KAFKA-7740: --- Fix Version/s: 2.5.0 > Kafka Admin Client should be able to manage user/client configurations for >

[jira] [Commented] (KAFKA-7740) Kafka Admin Client should be able to manage user/client configurations for users and clients

2020-01-22 Thread Brian Byrne (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021612#comment-17021612 ] Brian Byrne commented on KAFKA-7740: This will be resolved as a function of KIP-546, which is planned

[jira] [Commented] (KAFKA-9465) Enclose consumer call with catching InvalidOffsetException

2020-01-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021585#comment-17021585 ] ASF GitHub Bot commented on KAFKA-9465: --- tedyu commented on pull request #8001: KAFKA-9465: Enclose

[jira] [Created] (KAFKA-9465) Enclose consumer call with catching InvalidOffsetException

2020-01-22 Thread Ted Yu (Jira)
Ted Yu created KAFKA-9465: - Summary: Enclose consumer call with catching InvalidOffsetException Key: KAFKA-9465 URL: https://issues.apache.org/jira/browse/KAFKA-9465 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9417) Integration test for new EOS model with vanilla Producer and Consumer

2020-01-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021558#comment-17021558 ] ASF GitHub Bot commented on KAFKA-9417: --- abbccdda commented on pull request #8000: (WIP)

[jira] [Updated] (KAFKA-9417) Integration test for new EOS model with vanilla Producer and Consumer

2020-01-22 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9417: --- Description: We would like to extend the `TransactionMessageCopier` to use the new subscription

[jira] [Updated] (KAFKA-9417) Integration test for new EOS model with vanilla Producer and Consumer

2020-01-22 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9417: --- Summary: Integration test for new EOS model with vanilla Producer and Consumer (was: Add extension

[jira] [Commented] (KAFKA-9464) Close the producer in completeShutdown

2020-01-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021548#comment-17021548 ] ASF GitHub Bot commented on KAFKA-9464: --- tedyu commented on pull request #7999: KAFKA-9464: Close

[jira] [Resolved] (KAFKA-9418) Add new sendOffsets API to include consumer group metadata

2020-01-22 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9418. Fix Version/s: 2.5.0 Resolution: Fixed > Add new sendOffsets API to include

[jira] [Commented] (KAFKA-9418) Add new sendOffsets API to include consumer group metadata

2020-01-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021546#comment-17021546 ] ASF GitHub Bot commented on KAFKA-9418: --- hachikuji commented on pull request #7952: KAFKA-9418: Add

[jira] [Created] (KAFKA-9464) Close the producer in completeShutdown

2020-01-22 Thread Ted Yu (Jira)
Ted Yu created KAFKA-9464: - Summary: Close the producer in completeShutdown Key: KAFKA-9464 URL: https://issues.apache.org/jira/browse/KAFKA-9464 Project: Kafka Issue Type: Bug Reporter:

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2020-01-22 Thread Andy Coates (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021338#comment-17021338 ] Andy Coates commented on KAFKA-8377: This also causes 

[jira] [Commented] (KAFKA-9460) Enable TLSv1.2 by default and disable all others protocol versions

2020-01-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021304#comment-17021304 ] ASF GitHub Bot commented on KAFKA-9460: --- nizhikov commented on pull request #7998: KAFKA-9460:

[jira] [Commented] (KAFKA-7273) Converters should have access to headers.

2020-01-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021270#comment-17021270 ] ASF GitHub Bot commented on KAFKA-7273: --- rhauch commented on pull request #7489: KAFKA-7273