[jira] [Commented] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031237#comment-17031237 ] Guozhang Wang commented on KAFKA-9430: -- I see your point, we can expose this from the

[jira] [Resolved] (KAFKA-9447) Add examples for EOS standalone and group mode under kafka/examples

[ https://issues.apache.org/jira/browse/KAFKA-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9447. Resolution: Fixed > Add examples for EOS standalone and group mode under kafka/examples >

[jira] [Commented] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

[ https://issues.apache.org/jira/browse/KAFKA-9512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031177#comment-17031177 ] Guozhang Wang commented on KAFKA-9512: -- Did you see it in Scala 2.13 or other Scala versions? I also

[jira] [Created] (KAFKA-9513) Failed GroupMetadataManager loadGroupAndOffsets will consider groups as loaded

Lucas Bradstreet created KAFKA-9513: --- Summary: Failed GroupMetadataManager loadGroupAndOffsets will consider groups as loaded Key: KAFKA-9513 URL: https://issues.apache.org/jira/browse/KAFKA-9513

[jira] [Commented] (KAFKA-8896) NoSuchElementException after coordinator move

[ https://issues.apache.org/jira/browse/KAFKA-8896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031170#comment-17031170 ] Jason Gustafson commented on KAFKA-8896: [~francisco.juan] The fix version is 2.2.2. Can you

[jira] [Commented] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031166#comment-17031166 ] Vinoth Chandar commented on KAFKA-9430: --- [~guozhang] IIUC that change you point out, has simplified

[jira] [Commented] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

[ https://issues.apache.org/jira/browse/KAFKA-9512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031169#comment-17031169 ] Vinoth Chandar commented on KAFKA-9512: --- I have run this locally over 15 times.. without luck.. 

[jira] [Commented] (KAFKA-9447) Add examples for EOS standalone and group mode under kafka/examples

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

[jira] [Commented] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

[ https://issues.apache.org/jira/browse/KAFKA-9512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031157#comment-17031157 ] Vinoth Chandar commented on KAFKA-9512: --- I will try to reproduce this locally and investigate.. 

[jira] [Commented] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

[ https://issues.apache.org/jira/browse/KAFKA-9512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031156#comment-17031156 ] Vinoth Chandar commented on KAFKA-9512: --- {code:java}

[jira] [Resolved] (KAFKA-8164) Improve test passing rate by rerunning flaky tests

[ https://issues.apache.org/jira/browse/KAFKA-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8164. Fix Version/s: 2.6.0 Resolution: Fixed > Improve test passing rate by rerunning flaky tests

[jira] [Commented] (KAFKA-8164) Improve test passing rate by rerunning flaky tests

[ https://issues.apache.org/jira/browse/KAFKA-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031153#comment-17031153 ] Ismael Juma commented on KAFKA-8164: We are doing this just for Jenkins PR builds, retries are

[jira] [Commented] (KAFKA-8164) Improve test passing rate by rerunning flaky tests

[ https://issues.apache.org/jira/browse/KAFKA-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031151#comment-17031151 ] ASF GitHub Bot commented on KAFKA-8164: --- ijuma commented on pull request #8019: KAFKA-8164: Improve

[jira] [Commented] (KAFKA-9007) Flaky Test kafka.api.SaslPlaintextConsumerTest.testCoordinatorFailover

[ https://issues.apache.org/jira/browse/KAFKA-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031122#comment-17031122 ] Matthias J. Sax commented on KAFKA-9007:

[jira] [Commented] (KAFKA-8266) Improve `testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup`

[ https://issues.apache.org/jira/browse/KAFKA-8266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031121#comment-17031121 ] Matthias J. Sax commented on KAFKA-8266: This test is rather flaky, cf. KAFKA-7965. It might be

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031119#comment-17031119 ] Matthias J. Sax commented on KAFKA-7965:

[jira] [Created] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

Matthias J. Sax created KAFKA-9512: -- Summary: Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration Key: KAFKA-9512 URL: https://issues.apache.org/jira/browse/KAFKA-9512 Project: Kafka

[jira] [Assigned] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

[ https://issues.apache.org/jira/browse/KAFKA-9512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9512: -- Assignee: Vinoth Chandar > Flaky Test

[jira] [Commented] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031116#comment-17031116 ] Matthias J. Sax commented on KAFKA-8211:

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031115#comment-17031115 ] Matthias J. Sax commented on KAFKA-8110:

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031114#comment-17031114 ] Matthias J. Sax commented on KAFKA-8110:

[jira] [Updated] (KAFKA-9511) Return more specific error and message when producer.initTransaction fails due to missing Kafka configs

[ https://issues.apache.org/jira/browse/KAFKA-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhang updated KAFKA-9511: Description: If a user is running a single Kafka broker and tries to initialize a transaction

[jira] [Updated] (KAFKA-9511) Return more specific error and message when producer.initTransaction fails due to missing Kafka configs

[ https://issues.apache.org/jira/browse/KAFKA-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhang updated KAFKA-9511: Description: If a user is running a single Kafka broker and tries to initialize a transaction

[jira] [Created] (KAFKA-9511) Return more specific error and message when producer.initTransaction fails due to missing Kafka configs

Steven Zhang created KAFKA-9511: --- Summary: Return more specific error and message when producer.initTransaction fails due to missing Kafka configs Key: KAFKA-9511 URL:

[jira] [Updated] (KAFKA-9511) Return more specific error and message when producer.initTransaction fails due to missing Kafka configs

[ https://issues.apache.org/jira/browse/KAFKA-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhang updated KAFKA-9511: Description: If a user is running a single Kafka broker and tries to initialize a transaction

[jira] [Commented] (KAFKA-9510) Quotas may resolve to incorrect value if user is empty

[ https://issues.apache.org/jira/browse/KAFKA-9510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031080#comment-17031080 ] Brian Byrne commented on KAFKA-9510: Here's another one that may be more common. /config/clients/,

[jira] [Updated] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9509: - Fix Version/s: 2.5.0 > Fix flaky test MirrorConnectorsIntegrationTest.testReplication >

[jira] [Updated] (KAFKA-9508) Kafka connect handling of database length checks

[ https://issues.apache.org/jira/browse/KAFKA-9508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rahul Battacharya updated KAFKA-9508: - Description: Kafka connectors which interact with database specially sink connectors

[jira] [Updated] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9509: - Description: The test

[jira] [Commented] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031074#comment-17031074 ] ASF GitHub Bot commented on KAFKA-9509: --- skaundinya15 commented on pull request #8048: KAFKA-9509:

[jira] [Created] (KAFKA-9510) Quotas may resolve to incorrect value if user is empty

Brian Byrne created KAFKA-9510: -- Summary: Quotas may resolve to incorrect value if user is empty Key: KAFKA-9510 URL: https://issues.apache.org/jira/browse/KAFKA-9510 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya reassigned KAFKA-9509: Assignee: Sanjana Kaundinya > Fix flaky test

[jira] [Created] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

Sanjana Kaundinya created KAFKA-9509: Summary: Fix flaky test MirrorConnectorsIntegrationTest.testReplication Key: KAFKA-9509 URL: https://issues.apache.org/jira/browse/KAFKA-9509 Project: Kafka

[jira] [Created] (KAFKA-9508) Kafka connect handling of database length checks

Rahul Battacharya created KAFKA-9508: Summary: Kafka connect handling of database length checks Key: KAFKA-9508 URL: https://issues.apache.org/jira/browse/KAFKA-9508 Project: Kafka Issue

[jira] [Assigned] (KAFKA-8820) Use Admin API of Replica Reassignment in CLI tools

[ https://issues.apache.org/jira/browse/KAFKA-8820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe reassigned KAFKA-8820: --- Assignee: Colin McCabe (was: Steve Rodrigues) > Use Admin API of Replica Reassignment in

[jira] [Commented] (KAFKA-8820) Use Admin API of Replica Reassignment in CLI tools

[ https://issues.apache.org/jira/browse/KAFKA-8820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031022#comment-17031022 ] Colin McCabe commented on KAFKA-8820: - Hi [~steverod], I'll take this JIRA as per our offline

[jira] [Created] (KAFKA-9507) AdminClient should check for missing committed offsets

Jason Gustafson created KAFKA-9507: -- Summary: AdminClient should check for missing committed offsets Key: KAFKA-9507 URL: https://issues.apache.org/jira/browse/KAFKA-9507 Project: Kafka

[jira] [Updated] (KAFKA-9507) AdminClient should check for missing committed offsets

[ https://issues.apache.org/jira/browse/KAFKA-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9507: --- Labels: newbie (was: ) > AdminClient should check for missing committed offsets >

[jira] [Assigned] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9390: --- Assignee: John Roesler > Non-key joining of KTable not compatible with confluent avro

[jira] [Closed] (KAFKA-9477) Doc: Add RoundRobinAssignor as an option to consumer configs

[ https://issues.apache.org/jira/browse/KAFKA-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandra Rodoni closed KAFKA-9477. --- > Doc: Add RoundRobinAssignor as an option to consumer configs >

[jira] [Updated] (KAFKA-9477) Doc: Add RoundRobinAssignor as an option to consumer configs

[ https://issues.apache.org/jira/browse/KAFKA-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandra Rodoni updated KAFKA-9477: Fix Version/s: 2.5.0 > Doc: Add RoundRobinAssignor as an option to consumer configs >

[jira] [Created] (KAFKA-9506) Fix JmxReporter corner cases and optimize

Colin McCabe created KAFKA-9506: --- Summary: Fix JmxReporter corner cases and optimize Key: KAFKA-9506 URL: https://issues.apache.org/jira/browse/KAFKA-9506 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7870) Error sending fetch request (sessionId=1578860481, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read.

[ https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030903#comment-17030903 ] SVETLANA PETROVA commented on KAFKA-7870: - We have the same problem with kafka 2.12-2.3.0. Any

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030864#comment-17030864 ] Jun Rao commented on KAFKA-4084: [~evanjpw]: I am not sure if you need the new config. The controller

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030842#comment-17030842 ] ASF GitHub Bot commented on KAFKA-7509: --- rhauch commented on pull request #5876: KAFKA-7509: Avoid

[jira] [Resolved] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-7509. -- Resolution: Won't Fix > Kafka Connect logs unnecessary warnings about unused configurations >

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030839#comment-17030839 ] Randall Hauch commented on KAFKA-7509: -- KAFKA-6793 and 

[jira] [Resolved] (KAFKA-9261) NPE when updating client metadata

[ https://issues.apache.org/jira/browse/KAFKA-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9261. Resolution: Fixed > NPE when updating client metadata > -

[jira] [Updated] (KAFKA-9261) NPE when updating client metadata

[ https://issues.apache.org/jira/browse/KAFKA-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9261: --- Affects Version/s: 2.3.0 2.3.1 > NPE when updating client metadata >

[jira] [Resolved] (KAFKA-9427) StateRestoreListener.onRestoreEnd should report actual message count

[ https://issues.apache.org/jira/browse/KAFKA-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9427. -- Resolution: Fixed This has been fixed as part of KAFKA-9113. >

[jira] [Resolved] (KAFKA-9113) Clean up task management

[ https://issues.apache.org/jira/browse/KAFKA-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9113. -- Fix Version/s: 2.6.0 Resolution: Fixed This clean is done in trunk (2.6.0) now. >

[jira] [Commented] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030829#comment-17030829 ] Guozhang Wang commented on KAFKA-8574: -- As part of KAFKA-9113 we have moved the reading of

[jira] [Resolved] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8574. -- Fix Version/s: 2.6.0 Assignee: Guozhang Wang Resolution: Fixed > EOS race

[jira] [Commented] (KAFKA-9261) NPE when updating client metadata

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

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030825#comment-17030825 ] Evan Williams commented on KAFKA-4084: -- Thanks [~junrao] Totally agree.  # Set dynamic cluster

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030819#comment-17030819 ] Jun Rao commented on KAFKA-4084: [~evanjpw]: # For this case, you do have to script up things yourself.

[jira] [Commented] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030754#comment-17030754 ] Randall Hauch commented on KAFKA-7489: -- Merged [https://github.com/apache/kafka/pull/8035] to the

[jira] [Commented] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version

[ https://issues.apache.org/jira/browse/KAFKA-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030752#comment-17030752 ] ASF GitHub Bot commented on KAFKA-7489: --- rhauch commented on pull request #8035: KAFKA-7489: Remove

[jira] [Commented] (KAFKA-6793) Unnecessary warning log message

[ https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030688#comment-17030688 ] ASF GitHub Bot commented on KAFKA-6793: --- artjock commented on pull request #8043: KAFKA-6793: