[jira] [Updated] (KAFKA-13045) Add test for batched OffsetFetch requests where we have the same group in the request appear more than once

[ https://issues.apache.org/jira/browse/KAFKA-13045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-13045: -- Description: Now that we have https://issues.apache.org/jira/browse/KAFKA-12234 

[jira] [Updated] (KAFKA-13045) Add test for batched OffsetFetch requests where we have the same group in the request twice

[ https://issues.apache.org/jira/browse/KAFKA-13045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-13045: -- Description: Now that we have https://issues.apache.org/jira/browse/KAFKA-12234 

[jira] [Updated] (KAFKA-13045) Add test for batched OffsetFetch requests where we have the same group in the request appear more than once

[ https://issues.apache.org/jira/browse/KAFKA-13045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-13045: -- Summary: Add test for batched OffsetFetch requests where we have the same group in

[jira] [Updated] (KAFKA-13045) Add test for batched OffsetFetch requests where we have the same group in the request twice

[ https://issues.apache.org/jira/browse/KAFKA-13045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-13045: -- Description: Now that we have https://issues.apache.org/jira/browse/KAFKA-12234 

[jira] [Created] (KAFKA-13045) Add test for batched OffsetFetch requests where we have the same group in the request twice.

Sanjana Kaundinya created KAFKA-13045: - Summary: Add test for batched OffsetFetch requests where we have the same group in the request twice. Key: KAFKA-13045 URL:

[jira] [Updated] (KAFKA-13045) Add test for batched OffsetFetch requests where we have the same group in the request twice

[ https://issues.apache.org/jira/browse/KAFKA-13045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-13045: -- Fix Version/s: 3.0.0 > Add test for batched OffsetFetch requests where we have the

[jira] [Assigned] (KAFKA-13045) Add test for batched OffsetFetch requests where we have the same group in the request twice

[ https://issues.apache.org/jira/browse/KAFKA-13045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya reassigned KAFKA-13045: - Assignee: Sanjana Kaundinya > Add test for batched OffsetFetch requests where

[jira] [Updated] (KAFKA-13045) Add test for batched OffsetFetch requests where we have the same group in the request twice

[ https://issues.apache.org/jira/browse/KAFKA-13045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-13045: -- Affects Version/s: 3.0.0 > Add test for batched OffsetFetch requests where we have

[jira] [Updated] (KAFKA-13045) Add test for batched OffsetFetch requests where we have the same group in the request twice

[ https://issues.apache.org/jira/browse/KAFKA-13045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-13045: -- Summary: Add test for batched OffsetFetch requests where we have the same group in

[jira] [Updated] (KAFKA-13045) Add test for batched OffsetFetch requests where we have the same group in the request twice

[ https://issues.apache.org/jira/browse/KAFKA-13045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-13045: -- Priority: Minor (was: Major) > Add test for batched OffsetFetch requests where we

[jira] [Assigned] (KAFKA-12234) Extend OffsetFetch requests to accept multiple group ids.

[ https://issues.apache.org/jira/browse/KAFKA-12234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya reassigned KAFKA-12234: - Assignee: Sanjana Kaundinya > Extend OffsetFetch requests to accept multiple

[jira] [Resolved] (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 ] Sanjana Kaundinya resolved KAFKA-9678. -- Resolution: Duplicate > Introduce bounded exponential backoff in clients >

[jira] [Reopened] (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 ] Sanjana Kaundinya reopened KAFKA-9678: -- > Introduce bounded exponential backoff in clients >

[jira] [Resolved] (KAFKA-9893) Configurable TCP connection timeout and improve the initial metadata fetch

[ https://issues.apache.org/jira/browse/KAFKA-9893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya resolved KAFKA-9893. -- Resolution: Implemented > Configurable TCP connection timeout and improve the initial

[jira] [Comment Edited] (KAFKA-9800) [KIP-580] Client Exponential Backoff Implementation

[ https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124340#comment-17124340 ] Sanjana Kaundinya edited comment on KAFKA-9800 at 6/24/20, 4:24 AM:

[jira] [Comment Edited] (KAFKA-9800) [KIP-580] Client Exponential Backoff Implementation

[ https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124340#comment-17124340 ] Sanjana Kaundinya edited comment on KAFKA-9800 at 6/24/20, 4:24 AM:

[jira] [Resolved] (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 ] Sanjana Kaundinya resolved KAFKA-9678. -- Resolution: Duplicate > Introduce bounded exponential backoff in clients >

[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=17143505#comment-17143505 ] Sanjana Kaundinya commented on KAFKA-9678: -- The work for this is being done by [~d8tltanc] in

[jira] [Commented] (KAFKA-9800) [KIP-580] Client Exponential Backoff Implementation

[ https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124340#comment-17124340 ] Sanjana Kaundinya commented on KAFKA-9800: -- Here are my thoughts: 1) There should be no changes

[jira] [Created] (KAFKA-10021) When reading to the end of the config log, check if fetch.max.wait.ms is greater than worker.sync.timeout.ms

Sanjana Kaundinya created KAFKA-10021: - Summary: When reading to the end of the config log, check if fetch.max.wait.ms is greater than worker.sync.timeout.ms Key: KAFKA-10021 URL:

[jira] [Updated] (KAFKA-9988) Connect incorrectly reports task has failed when task takes too long to shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9988: - Affects Version/s: 2.5.1 2.4.2 2.3.2

[jira] [Updated] (KAFKA-9988) Log incorrectly reports task has failed when task takes too long to shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9988: - Description: If the OffsetStorageReader is closed while the task is trying to shutdown,

[jira] [Updated] (KAFKA-9988) Connect incorrectly reports task has failed when task takes too long to shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9988: - Summary: Connect incorrectly reports task has failed when task takes too long to

[jira] [Created] (KAFKA-9988) Log incorrectly reports task has failed when task takes too long to shutdown

Sanjana Kaundinya created KAFKA-9988: Summary: Log incorrectly reports task has failed when task takes too long to shutdown Key: KAFKA-9988 URL: https://issues.apache.org/jira/browse/KAFKA-9988

[jira] [Closed] (KAFKA-9625) Unable to Describe broker configurations that have been set via IncrementalAlterConfigs

[ https://issues.apache.org/jira/browse/KAFKA-9625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya closed KAFKA-9625. > Unable to Describe broker configurations that have been set via > IncrementalAlterConfigs >

[jira] [Closed] (KAFKA-9047) AdminClient group operations may not respect backoff

[ https://issues.apache.org/jira/browse/KAFKA-9047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya closed KAFKA-9047. > AdminClient group operations may not respect backoff >

[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=17059128#comment-17059128 ] Sanjana Kaundinya commented on KAFKA-9678: -- I have a KIP out for this here:

[jira] [Updated] (KAFKA-9621) AdminClient listOffsets operation does not respect retries and backoff

[ https://issues.apache.org/jira/browse/KAFKA-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9621: - Description: Similar to https://issues.apache.org/jira/browse/KAFKA-9047, currently the

[jira] [Updated] (KAFKA-9621) AdminClient listOffsets operation does not respect retries and backoff

[ https://issues.apache.org/jira/browse/KAFKA-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9621: - Description: Similar to https://issues.apache.org/jira/browse/KAFKA-9047, currently the

[jira] [Created] (KAFKA-9621) AdminClient listOffsets operation does not respect retries and backoff

Sanjana Kaundinya created KAFKA-9621: Summary: AdminClient listOffsets operation does not respect retries and backoff Key: KAFKA-9621 URL: https://issues.apache.org/jira/browse/KAFKA-9621

[jira] [Updated] (KAFKA-9047) AdminClient group operations may not respect backoff

[ https://issues.apache.org/jira/browse/KAFKA-9047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9047: - Reviewer: Jason Gustafson > AdminClient group operations may not respect backoff >

[jira] [Updated] (KAFKA-9580) Log clearer error messages when there is an offset out of range

[ https://issues.apache.org/jira/browse/KAFKA-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9580: - Description: Currently in the broker side logs, when an exception due to offset out of

[jira] [Updated] (KAFKA-9580) Log clearer error messages when there is an offset out of range

[ https://issues.apache.org/jira/browse/KAFKA-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9580: - Description: Currently in the broker side logs, when an exception due to offset out of

[jira] [Created] (KAFKA-9580) Log clearer error messages when there is an offset out of range

Sanjana Kaundinya created KAFKA-9580: Summary: Log clearer error messages when there is an offset out of range Key: KAFKA-9580 URL: https://issues.apache.org/jira/browse/KAFKA-9580 Project: Kafka

[jira] [Resolved] (KAFKA-9306) Kafka Consumer does not clean up all metrics after shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya resolved KAFKA-9306. -- Fix Version/s: 2.4.1 Resolution: Fixed > Kafka Consumer does not clean up all

[jira] [Created] (KAFKA-9558) getListOffsetsCalls doesn't update node in case of leader change

Sanjana Kaundinya created KAFKA-9558: Summary: getListOffsetsCalls doesn't update node in case of leader change Key: KAFKA-9558 URL: https://issues.apache.org/jira/browse/KAFKA-9558 Project:

[jira] [Assigned] (KAFKA-9047) AdminClient group operations may not respect backoff

[ https://issues.apache.org/jira/browse/KAFKA-9047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya reassigned KAFKA-9047: Assignee: Sanjana Kaundinya (was: Vikas Singh) > AdminClient group operations

[jira] [Created] (KAFKA-9520) Deprecate ZooKeeper access for kafka-reassign-partitions.sh

Sanjana Kaundinya created KAFKA-9520: Summary: Deprecate ZooKeeper access for kafka-reassign-partitions.sh Key: KAFKA-9520 URL: https://issues.apache.org/jira/browse/KAFKA-9520 Project: Kafka

[jira] [Created] (KAFKA-9519) Deprecate ZooKeeper access for kafka-configs.sh

Sanjana Kaundinya created KAFKA-9519: Summary: Deprecate ZooKeeper access for kafka-configs.sh Key: KAFKA-9519 URL: https://issues.apache.org/jira/browse/KAFKA-9519 Project: Kafka

[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-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] [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-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState

Sanjana Kaundinya created KAFKA-8945: Summary: Incorrect null check in the constructor for ConnectorHealth and AbstractState Key: KAFKA-8945 URL: https://issues.apache.org/jira/browse/KAFKA-8945