[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224844#comment-17224844 ] Matthias J. Sax commented on KAFKA-4628: There was a discussion

[jira] [Assigned] (KAFKA-10669) ListOffsetRequest: make CurrentLeaderEpoch field ignorable and set MaxNumOffsets field to 1

[ https://issues.apache.org/jira/browse/KAFKA-10669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-10669: - Assignee: Manikumar > ListOffsetRequest: make CurrentLeaderEpoch field ignorable and set >

[jira] [Created] (KAFKA-10673) ConnectionQuotas should cache interbroker listener name

David Mao created KAFKA-10673: - Summary: ConnectionQuotas should cache interbroker listener name Key: KAFKA-10673 URL: https://issues.apache.org/jira/browse/KAFKA-10673 Project: Kafka Issue

[jira] [Resolved] (KAFKA-10669) ListOffsetRequest: make CurrentLeaderEpoch field ignorable and set MaxNumOffsets field to 1

[ https://issues.apache.org/jira/browse/KAFKA-10669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-10669. --- Resolution: Fixed Issue resolved by pull request 9540 [https://github.com/apache/kafka/pull/9540]

[jira] [Commented] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224839#comment-17224839 ] Matthias J. Sax commented on KAFKA-10629: - Absolutely [~rohitdeshaws] – note, that this ticket

[jira] [Created] (KAFKA-10674) Brokers should know the active controller ApiVersion after enabling KIP-590 forwarding

Boyang Chen created KAFKA-10674: --- Summary: Brokers should know the active controller ApiVersion after enabling KIP-590 forwarding Key: KAFKA-10674 URL: https://issues.apache.org/jira/browse/KAFKA-10674

[jira] [Assigned] (KAFKA-10342) Migrate remaining RPCs to forward to the controller

[ https://issues.apache.org/jira/browse/KAFKA-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10342: --- Assignee: Boyang Chen > Migrate remaining RPCs to forward to the controller >

[jira] [Updated] (KAFKA-10342) Migrate remaining RPCs to forward to the controller

[ https://issues.apache.org/jira/browse/KAFKA-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10342: Summary: Migrate remaining RPCs to forward to the controller (was: Redirect remaining RPCs to

[jira] [Updated] (KAFKA-10342) Redirect remaining RPCs to the controller

[ https://issues.apache.org/jira/browse/KAFKA-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10342: Description: This ticket tracks the progress along migrating the rest of RPCs to the controller

[jira] [Updated] (KAFKA-10342) Redirect remaining RPCs to the controller

[ https://issues.apache.org/jira/browse/KAFKA-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10342: Summary: Redirect remaining RPCs to the controller (was: Redirect Create/DeleteAcls to the

[jira] [Commented] (KAFKA-10643) Static membership - repetitive PreparingRebalance with updating metadata for member reason

[ https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225073#comment-17225073 ] A. Sophie Blee-Goldman commented on KAFKA-10643: Can you be a little more specific about

[jira] [Created] (KAFKA-10675) Error message from ConnectSchema.validateValue() should include the name of the schema.

Alexander Iskuskov created KAFKA-10675: -- Summary: Error message from ConnectSchema.validateValue() should include the name of the schema. Key: KAFKA-10675 URL:

[jira] [Updated] (KAFKA-10675) Error message from ConnectSchema.validateValue() should include the name of the schema.

[ https://issues.apache.org/jira/browse/KAFKA-10675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Iskuskov updated KAFKA-10675: --- External issue URL: https://github.com/apache/kafka/pull/9541 > Error message from

[jira] [Resolved] (KAFKA-10632) Raft client should push all committed data to listeners

[ https://issues.apache.org/jira/browse/KAFKA-10632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10632. - Resolution: Fixed > Raft client should push all committed data to listeners >

[jira] [Commented] (KAFKA-10614) Group coordinator onElection/onResignation should guard against leader epoch

[ https://issues.apache.org/jira/browse/KAFKA-10614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224992#comment-17224992 ] Bruno Cadonna commented on KAFKA-10614: --- FYI: This bug makes system test

[jira] [Created] (KAFKA-10676) Decide whether Raft listener callback errors are fatal

Jason Gustafson created KAFKA-10676: --- Summary: Decide whether Raft listener callback errors are fatal Key: KAFKA-10676 URL: https://issues.apache.org/jira/browse/KAFKA-10676 Project: Kafka

[jira] [Created] (KAFKA-10677) Complete fetches in purgatory immediately after raft leader resigns

Jason Gustafson created KAFKA-10677: --- Summary: Complete fetches in purgatory immediately after raft leader resigns Key: KAFKA-10677 URL: https://issues.apache.org/jira/browse/KAFKA-10677 Project:

[jira] [Resolved] (KAFKA-10343) Add IBP based ApiVersion constraint tests

[ https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10343. - Resolution: Won't Fix We are planning to work on a more long-term fix for this issue, see  >

[jira] [Comment Edited] (KAFKA-10343) Add IBP based ApiVersion constraint tests

[ https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225029#comment-17225029 ] Boyang Chen edited comment on KAFKA-10343 at 11/3/20, 12:32 AM: We are

[jira] [Commented] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225189#comment-17225189 ] Rohit Deshpande commented on KAFKA-10629: - Thanks [~mjsax] Created

[jira] [Comment Edited] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225189#comment-17225189 ] Rohit Deshpande edited comment on KAFKA-10629 at 11/3/20, 7:20 AM: ---

[jira] [Comment Edited] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225189#comment-17225189 ] Rohit Deshpande edited comment on KAFKA-10629 at 11/3/20, 7:21 AM: ---

[jira] [Commented] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224555#comment-17224555 ] Bruno Cadonna commented on KAFKA-10633: --- [~thebearmayor] [~eran-levy] FYI: The 2.6.1 release is

[jira] [Commented] (KAFKA-10666) Kafka doesn't use keystore / key / truststore passwords for named SSL connections

[ https://issues.apache.org/jira/browse/KAFKA-10666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224605#comment-17224605 ] lqjacklee commented on KAFKA-10666: --- [~pfjason] checked the code. we just load the configuration from

[jira] [Assigned] (KAFKA-9892) Producer state snapshot needs to be forced to disk

[ https://issues.apache.org/jira/browse/KAFKA-9892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brajesh Kumar reassigned KAFKA-9892: - Assignee: Brajesh Kumar > Producer state snapshot needs to be forced to disk >

[jira] [Assigned] (KAFKA-9892) Producer state snapshot needs to be forced to disk

[ https://issues.apache.org/jira/browse/KAFKA-9892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brajesh Kumar reassigned KAFKA-9892: - Assignee: (was: Brajesh Kumar) > Producer state snapshot needs to be forced to

[jira] [Assigned] (KAFKA-9892) Producer state snapshot needs to be forced to disk

[ https://issues.apache.org/jira/browse/KAFKA-9892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brajesh Kumar reassigned KAFKA-9892: - Assignee: Brajesh Kumar > Producer state snapshot needs to be forced to disk >

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224651#comment-17224651 ] Sarita commented on KAFKA-7500: --- Hi [~ryannedolan] We are trying to set up MM2 with connection

[jira] [Commented] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224645#comment-17224645 ] Eran Levy commented on KAFKA-10633: --- thanks [~cadonna] [~thebearmayor] > Constant probing rebalances

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224651#comment-17224651 ] Sarita edited comment on KAFKA-7500 at 11/2/20, 1:07 PM: - Hi [~ryannedolan] We

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224651#comment-17224651 ] Sarita edited comment on KAFKA-7500 at 11/2/20, 1:07 PM: - Hi [~ryannedolan] We

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224651#comment-17224651 ] Sarita edited comment on KAFKA-7500 at 11/2/20, 1:09 PM: - Hi [~ryannedolan] We

[jira] [Commented] (KAFKA-10666) Kafka doesn't use keystore / key / truststore passwords for named SSL connections

[ https://issues.apache.org/jira/browse/KAFKA-10666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224720#comment-17224720 ] Jason commented on KAFKA-10666: --- Is the intended functionality that only one keystore, truststore, or key