[jira] [Commented] (KAFKA-9663) KafkaStreams.metadataForKey, queryMetadataForKey docs don't mention null

[ https://issues.apache.org/jira/browse/KAFKA-9663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053929#comment-17053929 ] ASF GitHub Bot commented on KAFKA-9663: --- mjsax commented on pull request #8228: KAFKA-9663: Doc

[jira] [Commented] (KAFKA-5604) All producer methods should raise `ProducerFencedException` after the first time.

[ https://issues.apache.org/jira/browse/KAFKA-5604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053907#comment-17053907 ] Xiang Zhang commented on KAFKA-5604: [~apurva] I wonder if this ticket should be closed, 

[jira] [Commented] (KAFKA-9501) Promote Standby tasks to active tasks without closing them

[ https://issues.apache.org/jira/browse/KAFKA-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053897#comment-17053897 ] ASF GitHub Bot commented on KAFKA-9501: --- ableegoldman commented on pull request #8248: KAFKA-9501:

[jira] [Assigned] (KAFKA-9501) Promote Standby tasks to active tasks without closing them

[ https://issues.apache.org/jira/browse/KAFKA-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9501: -- Assignee: Sophie Blee-Goldman > Promote Standby tasks to active tasks without

[jira] [Commented] (KAFKA-9678) Introduce bounded exponential backoff in clients

[ https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053886#comment-17053886 ] Ismael Juma commented on KAFKA-9678: We should probably follow the same approach as KIP-144:  

[jira] [Resolved] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-5722. - Resolution: Duplicate > Refactor ConfigCommand to use the AdminClient >

[jira] [Created] (KAFKA-9679) Mock consumer should behave consistent with actual consumer

Boyang Chen created KAFKA-9679: -- Summary: Mock consumer should behave consistent with actual consumer Key: KAFKA-9679 URL: https://issues.apache.org/jira/browse/KAFKA-9679 Project: Kafka Issue

[jira] [Created] (KAFKA-9678) Introduce bounded exponential backoff in clients

Guozhang Wang created KAFKA-9678: Summary: Introduce bounded exponential backoff in clients Key: KAFKA-9678 URL: https://issues.apache.org/jira/browse/KAFKA-9678 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-9662) Throttling system test fails when messages are produced before consumer starts up

[ https://issues.apache.org/jira/browse/KAFKA-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-9662. - Resolution: Fixed > Throttling system test fails when messages are produced before consumer >

[jira] [Assigned] (KAFKA-9678) Introduce bounded exponential backoff in clients

[ https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-9678: -- Assignee: Sanjana Kaundinya > Introduce bounded exponential backoff in clients >

[jira] [Updated] (KAFKA-9666) Transactional producer Epoch could not be reset

[ https://issues.apache.org/jira/browse/KAFKA-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9666: Fix Version/s: (was: 2.5.0) 2.6.0 > Transactional producer Epoch could not

[jira] [Updated] (KAFKA-9677) Low consume bandwidth quota may cause consumer not being able to fetch data

[ https://issues.apache.org/jira/browse/KAFKA-9677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-9677: Description: When we changed quota communication with KIP-219, fetch requests get throttled by

[jira] [Commented] (KAFKA-9668) Iterating over KafkaStreams.getAllMetadata() results in ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-9668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053751#comment-17053751 ] ASF GitHub Bot commented on KAFKA-9668: --- guozhangwang commented on pull request #8233: KAFKA-9668:

[jira] [Commented] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

[ https://issues.apache.org/jira/browse/KAFKA-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053749#comment-17053749 ] Michael K. Edwards commented on KAFKA-8421: --- Is this change going to be backported to the 2.4

[jira] [Commented] (KAFKA-9662) Throttling system test fails when messages are produced before consumer starts up

[ https://issues.apache.org/jira/browse/KAFKA-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053731#comment-17053731 ] ASF GitHub Bot commented on KAFKA-9662: --- mumrah commented on pull request #8227: KAFKA-9662: Wait

[jira] [Created] (KAFKA-9677) Low consume bandwidth quota may cause consumer not being able to fetch data

Anna Povzner created KAFKA-9677: --- Summary: Low consume bandwidth quota may cause consumer not being able to fetch data Key: KAFKA-9677 URL: https://issues.apache.org/jira/browse/KAFKA-9677 Project:

[jira] [Commented] (KAFKA-9677) Low consume bandwidth quota may cause consumer not being able to fetch data

[ https://issues.apache.org/jira/browse/KAFKA-9677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053839#comment-17053839 ] Jun Rao commented on KAFKA-9677: [~apovzner] : Thanks for finding this issue! I agree with your suggested

[jira] [Commented] (KAFKA-9676) Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

[ https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053774#comment-17053774 ] Matthias J. Sax commented on KAFKA-9676: This PR already adds some tests: 

[jira] [Updated] (KAFKA-9675) RocksDB metrics reported always at zero

[ https://issues.apache.org/jira/browse/KAFKA-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9675: --- Component/s: streams > RocksDB metrics reported always at zero >

[jira] [Commented] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053824#comment-17053824 ] ASF GitHub Bot commented on KAFKA-6145: --- ableegoldman commented on pull request #8246: KAFKA-6145:

[jira] [Commented] (KAFKA-8820) kafka-reassign-partitions.sh should support the KIP-455 API

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

[jira] [Commented] (KAFKA-8245) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdAllGroups

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

[jira] [Created] (KAFKA-9676) Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

Boyang Chen created KAFKA-9676: -- Summary: Add test coverage for new ActiveTaskCreator and StandbyTaskCreator Key: KAFKA-9676 URL: https://issues.apache.org/jira/browse/KAFKA-9676 Project: Kafka

[jira] [Commented] (KAFKA-8245) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdAllGroups

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

[jira] [Commented] (KAFKA-9674) Task corruption should also close the producer if necessary

[ https://issues.apache.org/jira/browse/KAFKA-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053696#comment-17053696 ] ASF GitHub Bot commented on KAFKA-9674: --- abbccdda commented on pull request #8242: KAFKA-9674:

[jira] [Commented] (KAFKA-7787) Add error specifications to KAFKA-7609

[ https://issues.apache.org/jira/browse/KAFKA-7787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053692#comment-17053692 ] ASF GitHub Bot commented on KAFKA-7787: --- tombentley commented on pull request #8240: KAFKA-7787:

[jira] [Commented] (KAFKA-7787) Add error specifications to KAFKA-7609

[ https://issues.apache.org/jira/browse/KAFKA-7787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053686#comment-17053686 ] Tom Bentley commented on KAFKA-7787: [~cmccabe] thanks for getting back to me. The UNKNOWN enum

[jira] [Assigned] (KAFKA-9675) RocksDB metrics reported always at zero

[ https://issues.apache.org/jira/browse/KAFKA-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-9675: Assignee: Bruno Cadonna > RocksDB metrics reported always at zero >

[jira] [Updated] (KAFKA-9675) RocksDB metrics reported always at zero

[ https://issues.apache.org/jira/browse/KAFKA-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9675: - Issue Type: Bug (was: Improvement) > RocksDB metrics reported always at zero >

[jira] [Created] (KAFKA-9675) RocksDB metrics reported always at zero

Michael Viamari created KAFKA-9675: -- Summary: RocksDB metrics reported always at zero Key: KAFKA-9675 URL: https://issues.apache.org/jira/browse/KAFKA-9675 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7787) Add error specifications to KAFKA-7609

[ https://issues.apache.org/jira/browse/KAFKA-7787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053667#comment-17053667 ] Colin McCabe commented on KAFKA-7787: - Hi [~tombentley], Sorry for the delay. We've been really

[jira] [Updated] (KAFKA-9674) Task corruption should also close the producer if necessary

[ https://issues.apache.org/jira/browse/KAFKA-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9674: --- Component/s: streams > Task corruption should also close the producer if necessary >

[jira] [Resolved] (KAFKA-9635) Should ConfigProvider.subscribe be deprecated?

[ https://issues.apache.org/jira/browse/KAFKA-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-9635. - Resolution: Duplicate Let's continue the discussion on the mailing list. > Should

[jira] [Commented] (KAFKA-9635) Should ConfigProvider.subscribe be deprecated?

[ https://issues.apache.org/jira/browse/KAFKA-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053655#comment-17053655 ] Colin McCabe commented on KAFKA-9635: - If we want a change notification feature (and I think we do)

[jira] [Created] (KAFKA-9674) Task corruption should also close the producer if necessary

Boyang Chen created KAFKA-9674: -- Summary: Task corruption should also close the producer if necessary Key: KAFKA-9674 URL: https://issues.apache.org/jira/browse/KAFKA-9674 Project: Kafka Issue

[jira] [Created] (KAFKA-9673) Conditionally apply SMTs

Tom Bentley created KAFKA-9673: -- Summary: Conditionally apply SMTs Key: KAFKA-9673 URL: https://issues.apache.org/jira/browse/KAFKA-9673 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-9666) Transactional producer Epoch could not be reset

[ https://issues.apache.org/jira/browse/KAFKA-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053596#comment-17053596 ] Jason Gustafson commented on KAFKA-9666: This seems not to be a regression. This was encountered

[jira] [Commented] (KAFKA-9666) Transactional producer Epoch could not be reset

[ https://issues.apache.org/jira/browse/KAFKA-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053595#comment-17053595 ] ASF GitHub Bot commented on KAFKA-9666: --- bob-barrett commented on pull request #8239: KAFKA-9666:

[jira] [Updated] (KAFKA-9666) Transactional producer Epoch could not be reset

[ https://issues.apache.org/jira/browse/KAFKA-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9666: --- Priority: Critical (was: Blocker) > Transactional producer Epoch could not be reset >

[jira] [Commented] (KAFKA-9130) Allow listing consumer groups per state

[ https://issues.apache.org/jira/browse/KAFKA-9130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053577#comment-17053577 ] ASF GitHub Bot commented on KAFKA-9130: --- mimaison commented on pull request #8238: KAFKA-9130:

[jira] [Commented] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053507#comment-17053507 ] ASF GitHub Bot commented on KAFKA-6145: --- vvcephei commented on pull request #8121: KAFKA-6145: Pt

[jira] [Commented] (KAFKA-9636) Simple join of two KTables fails

[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053492#comment-17053492 ] Paul Snively commented on KAFKA-9636: - John, Here are some even-more-tiny tweaks to the test.

[jira] [Updated] (KAFKA-9636) Simple join of two KTables fails

[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Snively updated KAFKA-9636: Attachment: merge_issue.zip > Simple join of two KTables fails >

[jira] [Updated] (KAFKA-9636) Simple join of two KTables fails

[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Snively updated KAFKA-9636: Attachment: (was: merge_issue.zip) > Simple join of two KTables fails >

[jira] [Updated] (KAFKA-9672) Dead brokers in ISR cause isr-expiration to fail with exception

[ https://issues.apache.org/jira/browse/KAFKA-9672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Yurchenko updated KAFKA-9672: -- Summary: Dead brokers in ISR cause isr-expiration to fail with exception (was: Dead broker in

[jira] [Created] (KAFKA-9672) Dead broker in ISR cause isr-expiration to fail with exception

Ivan Yurchenko created KAFKA-9672: - Summary: Dead broker in ISR cause isr-expiration to fail with exception Key: KAFKA-9672 URL: https://issues.apache.org/jira/browse/KAFKA-9672 Project: Kafka

[jira] [Commented] (KAFKA-9561) Update task input partitions when topic metadata changes

[ https://issues.apache.org/jira/browse/KAFKA-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1705#comment-1705 ] Stepanenko Vyacheslav commented on KAFKA-9561: -- [~bchen225242] could you please review >

[jira] [Assigned] (KAFKA-7983) supporting replication.throttled.replicas in dynamic broker configuration

[ https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rahul Agarwal reassigned KAFKA-7983: Assignee: (was: Rahul Agarwal) > supporting replication.throttled.replicas in dynamic

[jira] [Commented] (KAFKA-9609) Memory Leak in Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053313#comment-17053313 ] Sönke Liebau commented on KAFKA-9609: - To be honest I still think that this would be the wrong

[jira] [Commented] (KAFKA-9343) Make Kafka shell runnable on z/OS

[ https://issues.apache.org/jira/browse/KAFKA-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053259#comment-17053259 ] Shuo Zhang commented on KAFKA-9343: --- [~bwittwer] [~bbejeck], sorry I didn't notice your comments and

[jira] [Commented] (KAFKA-9648) kafka server should resize backlog when create serversocket

[ https://issues.apache.org/jira/browse/KAFKA-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053195#comment-17053195 ] li xiangyuan commented on KAFKA-9648: - [~junrao]: Yes 1412 is quite small, I have noticed that but

[jira] [Created] (KAFKA-9671) Support sha512sum file format

Aljoscha Pörtner created KAFKA-9671: --- Summary: Support sha512sum file format Key: KAFKA-9671 URL: https://issues.apache.org/jira/browse/KAFKA-9671 Project: Kafka Issue Type: Improvement

[jira] [Comment Edited] (KAFKA-9669) Kafka 2.4.0 Chokes on Filebeat 5.6 Produced Data

[ https://issues.apache.org/jira/browse/KAFKA-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053077#comment-17053077 ] Weichu Liu edited comment on KAFKA-9669 at 3/6/20, 8:11 AM: -With 2.4.1 RC0,