[jira] [Created] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

2023-12-19 Thread Philip Nee (Jira)
Philip Nee created KAFKA-16034: -- Summary: AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id Key: KAFKA-16034 URL: https://issues.apache.org/jira/browse/KAFKA-16034

[jira] [Updated] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

2023-12-19 Thread Philip Nee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-16034: --- Parent: KAFKA-14246 Issue Type: Sub-task (was: Bug) > AsyncKafkaConsumer will get Invalid R

[jira] [Commented] (KAFKA-16026) AsyncConsumer does not send a poll event to the background thread

2023-12-19 Thread Philip Nee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798843#comment-17798843 ] Philip Nee commented on KAFKA-16026: For the PR [15035|https://github.com/apache/kaf

Re: [PR] KAFKA-15870: Move new group coordinator metrics from Yammer to Metrics [kafka]

2023-12-19 Thread via GitHub
dajac commented on PR #14848: URL: https://github.com/apache/kafka/pull/14848#issuecomment-1863996596 Merged to trunk and 3.7. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

Re: [PR] KAFKA-15870: Move new group coordinator metrics from Yammer to Metrics [kafka]

2023-12-19 Thread via GitHub
dajac merged PR #14848: URL: https://github.com/apache/kafka/pull/14848 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or

Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka]

2023-12-19 Thread via GitHub
philipnee commented on PR #15035: URL: https://github.com/apache/kafka/pull/15035#issuecomment-1863986474 hi @cadonna - Thanks for putting time into the review. I've addressed your comments. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

Re: [PR] KAFKA-14505; [3/N] Wire WriteTxnMarkers API [kafka]

2023-12-19 Thread via GitHub
dajac commented on code in PR #14985: URL: https://github.com/apache/kafka/pull/14985#discussion_r1432348819 ## group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorShardTest.java: ## @@ -968,4 +971,34 @@ public void testCleanupGroupMetadata() {

Re: [PR] KAFKA-14505; [3/N] Wire WriteTxnMarkers API [kafka]

2023-12-19 Thread via GitHub
dajac commented on code in PR #14985: URL: https://github.com/apache/kafka/pull/14985#discussion_r1432346828 ## group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java: ## @@ -2414,6 +2424,67 @@ public void testReplayWithTombstone() {

Re: [PR] KAFKA-14505; [3/N] Wire WriteTxnMarkers API [kafka]

2023-12-19 Thread via GitHub
dajac commented on code in PR #14985: URL: https://github.com/apache/kafka/pull/14985#discussion_r1432340012 ## core/src/test/scala/unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala: ## @@ -511,4 +544,35 @@ class CoordinatorLoaderImplTest { new FetchDataInfo(ne

Re: [PR] KAFKA-14505; [3/N] Wire WriteTxnMarkers API [kafka]

2023-12-19 Thread via GitHub
dajac commented on code in PR #14985: URL: https://github.com/apache/kafka/pull/14985#discussion_r1432339221 ## core/src/test/scala/unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala: ## @@ -511,4 +544,35 @@ class CoordinatorLoaderImplTest { new FetchDataInfo(ne

Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka]

2023-12-19 Thread via GitHub
cadonna commented on code in PR #15035: URL: https://github.com/apache/kafka/pull/15035#discussion_r1432322309 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java: ## @@ -234,7 +235,8 @@ public long maximumTimeToWait(long currentTime

Re: [PR] Implement RemoteLogSizeBytes [kafka]

2023-12-19 Thread via GitHub
showuon commented on code in PR #15050: URL: https://github.com/apache/kafka/pull/15050#discussion_r1432303423 ## core/src/main/scala/kafka/log/UnifiedLog.scala: ## @@ -1585,6 +1585,12 @@ class UnifiedLog(@volatile var logStartOffset: Long, def onlyLocalLogSegmentsSize: Long

Re: [PR] KAFKA-16014: add RemoteLogMetadataCount metric [kafka]

2023-12-19 Thread via GitHub
kamalcph commented on code in PR #15026: URL: https://github.com/apache/kafka/pull/15026#discussion_r1432264764 ## core/src/main/scala/kafka/server/KafkaRequestHandler.scala: ## @@ -289,14 +289,14 @@ class BrokerTopicMetrics(name: Option[String], configOpt: java.util.Optional[K

Re: [PR] Implement RemoteLogSizeBytes [kafka]

2023-12-19 Thread via GitHub
kamalcph commented on code in PR #15050: URL: https://github.com/apache/kafka/pull/15050#discussion_r1432252882 ## core/src/main/scala/kafka/log/UnifiedLog.scala: ## @@ -1585,6 +1585,12 @@ class UnifiedLog(@volatile var logStartOffset: Long, def onlyLocalLogSegmentsSize: Long

Re: [PR] KAFKA-16002: Implement RemoteCopyLagSegments, RemoteDeleteLagBytes and RemoteDeleteLagSegments [kafka]

2023-12-19 Thread via GitHub
kamalcph commented on PR #15005: URL: https://github.com/apache/kafka/pull/15005#issuecomment-1863858511 https://github.com/apache/kafka/pull/15005#discussion_r1431092107 We can take this up in the next PR, otherwise the replica might report stale metrics. -- This is an automated

Re: [PR] KAFKA-16014: add RemoteLogMetadataCount metric [kafka]

2023-12-19 Thread via GitHub
showuon commented on code in PR #15026: URL: https://github.com/apache/kafka/pull/15026#discussion_r1432207715 ## core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java: ## @@ -701,16 +702,22 @@ void testRemoteLogManagerTasksAvgIdlePercentAndMetadataCountMetrics() throws

Re: [PR] KAFKA-16014: add RemoteLogMetadataCount metric [kafka]

2023-12-19 Thread via GitHub
showuon commented on code in PR #15026: URL: https://github.com/apache/kafka/pull/15026#discussion_r1432205258 ## core/src/test/scala/kafka/server/KafkaRequestHandlerTest.scala: ## @@ -321,4 +323,24 @@ class KafkaRequestHandlerTest { assertEquals(0, brokerTopicMetrics.remot

Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka]

2023-12-19 Thread via GitHub
philipnee commented on code in PR #15035: URL: https://github.com/apache/kafka/pull/15035#discussion_r1432202539 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java: ## @@ -234,7 +237,8 @@ public long maximumTimeToWait(long currentTi

Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka]

2023-12-19 Thread via GitHub
philipnee commented on code in PR #15035: URL: https://github.com/apache/kafka/pull/15035#discussion_r1432201481 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java: ## @@ -195,6 +195,7 @@ public NetworkClientDelegate.PollResult poll

Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka]

2023-12-19 Thread via GitHub
philipnee commented on code in PR #15035: URL: https://github.com/apache/kafka/pull/15035#discussion_r1432201197 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java: ## @@ -288,7 +288,7 @@ public CompletableFuture> addOffsetFetchR

Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka]

2023-12-19 Thread via GitHub
philipnee commented on code in PR #15035: URL: https://github.com/apache/kafka/pull/15035#discussion_r1432199885 ## clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java: ## @@ -660,14 +672,14 @@ private HeartbeatRequestManager creat

Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka]

2023-12-19 Thread via GitHub
philipnee commented on code in PR #15035: URL: https://github.com/apache/kafka/pull/15035#discussion_r1432199373 ## clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java: ## @@ -385,6 +386,7 @@ public void testWakeupAfterEmptyFetch() {

Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka]

2023-12-19 Thread via GitHub
philipnee commented on code in PR #15035: URL: https://github.com/apache/kafka/pull/15035#discussion_r1432199230 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java: ## @@ -136,7 +135,7 @@ private void process(final PollAppl

Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka]

2023-12-19 Thread via GitHub
philipnee commented on code in PR #15035: URL: https://github.com/apache/kafka/pull/15035#discussion_r1432199044 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -728,7 +732,6 @@ public boolean shouldSkipHeartbeat() { @O

Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka]

2023-12-19 Thread via GitHub
philipnee commented on code in PR #15035: URL: https://github.com/apache/kafka/pull/15035#discussion_r1432198577 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java: ## @@ -184,7 +184,9 @@ public NetworkClientDelegate.PollResult poll

Re: [PR] KAFKA-15874: Add metric and request log attribute for deprecated request api versions (KIP-896) [kafka]

2023-12-19 Thread via GitHub
ijuma commented on code in PR #15032: URL: https://github.com/apache/kafka/pull/15032#discussion_r1432179355 ## generator/src/main/java/org/apache/kafka/message/StructRegistry.java: ## @@ -110,6 +110,7 @@ private void addStructSpecs(Versions parentVersions, List fields) {

Re: [PR] KAFKA-15874: Add metric and request log attribute for deprecated request api versions (KIP-896) [kafka]

2023-12-19 Thread via GitHub
ijuma commented on code in PR #15032: URL: https://github.com/apache/kafka/pull/15032#discussion_r1432178897 ## core/src/test/scala/unit/kafka/network/RequestConvertToJsonTest.scala: ## @@ -118,6 +119,21 @@ class RequestConvertToJsonTest { assertEquals(expectedNode, actualN

Re: [PR] KAFKA-15874: Add metric and request log attribute for deprecated request api versions (KIP-896) [kafka]

2023-12-19 Thread via GitHub
hachikuji commented on code in PR #15032: URL: https://github.com/apache/kafka/pull/15032#discussion_r1432175567 ## generator/src/main/java/org/apache/kafka/message/StructRegistry.java: ## @@ -110,6 +110,7 @@ private void addStructSpecs(Versions parentVersions, List fields) {

Re: [PR] KAFKA-15366: Modify LogDirFailureTest for KRaft [kafka]

2023-12-19 Thread via GitHub
rondagostino merged PR #14977: URL: https://github.com/apache/kafka/pull/14977 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.ap

Re: [PR] KAFKA-15366: Modify LogDirFailureTest for KRaft [kafka]

2023-12-19 Thread via GitHub
rondagostino commented on PR #14977: URL: https://github.com/apache/kafka/pull/14977#issuecomment-1863734568 Test failures are unrelated/flakes. JDK 8 tests were clean. All tests in this PR passed. Merging to trunk and 3.7. -- This is an automated message from the Apache Git Service. T

Re: [PR] MINOR: Client state machine fix for transition to stable on initial empty assignment [kafka]

2023-12-19 Thread via GitHub
lianetm commented on PR #15033: URL: https://github.com/apache/kafka/pull/15033#issuecomment-1863701453 Test failures seem unrelated. I checked around `testCoordinatorFailover` that, even though it passes locally, it failed on the CI for the new consumer, but it's been failing for other rec

Re: [PR] Test refactor consumer close [kafka]

2023-12-19 Thread via GitHub
philipnee closed pull request #15036: Test refactor consumer close URL: https://github.com/apache/kafka/pull/15036 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscrib

Re: [PR] KAFKA-15592: Allow member to not sending a heartbeat when a group ID is configured [kafka]

2023-12-19 Thread via GitHub
philipnee closed pull request #14390: KAFKA-15592: Allow member to not sending a heartbeat when a group ID is configured URL: https://github.com/apache/kafka/pull/14390 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling

2023-12-19 Thread Philip Nee (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798772#comment-17798772 ] Philip Nee commented on KAFKA-16010: I thought KAFKA-16026 (fixing the max poll) wou

[jira] [Comment Edited] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing

2023-12-19 Thread Sabit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761 ] Sabit edited comment on KAFKA-16025 at 12/19/23 10:23 PM: -- I th

[jira] [Comment Edited] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing

2023-12-19 Thread Sabit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761 ] Sabit edited comment on KAFKA-16025 at 12/19/23 10:23 PM: -- I th

[jira] [Comment Edited] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing

2023-12-19 Thread Sabit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761 ] Sabit edited comment on KAFKA-16025 at 12/19/23 10:22 PM: -- I th

[jira] [Comment Edited] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing

2023-12-19 Thread Sabit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761 ] Sabit edited comment on KAFKA-16025 at 12/19/23 10:22 PM: -- I th

[jira] [Comment Edited] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing

2023-12-19 Thread Sabit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761 ] Sabit edited comment on KAFKA-16025 at 12/19/23 10:21 PM: -- I th

[jira] [Commented] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing

2023-12-19 Thread Sabit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761 ] Sabit commented on KAFKA-16025: --- I think this bug can occur when rebalancing is triggered

[jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

2023-12-19 Thread Phuc Hong Tran (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798760#comment-17798760 ] Phuc Hong Tran commented on KAFKA-15341: Got it. Thanks, [~showuon]  > Enabling

Re: [PR] KAFKA-14505; [3/N] Wire WriteTxnMarkers API [kafka]

2023-12-19 Thread via GitHub
jeffkbkim commented on code in PR #14985: URL: https://github.com/apache/kafka/pull/14985#discussion_r1431849588 ## core/src/test/scala/unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala: ## @@ -511,4 +544,35 @@ class CoordinatorLoaderImplTest { new FetchDataInf

Re: [PR] KAFKA-14412: Generalise over RocksDB WriteBatch [kafka]

2023-12-19 Thread via GitHub
ableegoldman merged PR #14853: URL: https://github.com/apache/kafka/pull/14853 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.ap

Re: [PR] KAFKA-14412: Generalise over RocksDB WriteBatch [kafka]

2023-12-19 Thread via GitHub
ableegoldman commented on PR #14853: URL: https://github.com/apache/kafka/pull/14853#issuecomment-1863466888 I honestly don't know...maybe try doing a rebase from trunk and force pushing? That can often clear up this sort of thing. Ideally we don't have to abandon this PR for a fresh one (j

[jira] [Updated] (KAFKA-15250) DefaultBackgroundThread is running tight loop

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15250: -- Issue Type: Bug (was: Improvement) > DefaultBackgroundThread is running tight loop >

[jira] [Updated] (KAFKA-15946) AsyncKafkaConsumer should retry commits on the application thread instead of auto-retry

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15946: -- Issue Type: Bug (was: Improvement) > AsyncKafkaConsumer should retry commits on the application threa

[jira] [Updated] (KAFKA-15872) Investigate autocommit retry logic

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15872: -- Issue Type: Task (was: Improvement) > Investigate autocommit retry logic > --

[jira] [Updated] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15991: -- Issue Type: Test (was: Task) > Flaky new consumer test testGroupIdNotNullAndValid > -

[jira] [Updated] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15775: -- Fix Version/s: 3.7.0 > Implement listTopics() and partitionFor() for the AsyncKafkaConsumer >

[jira] [Updated] (KAFKA-15548) Send GroupConsumerHeartbeatRequest on Consumer.close()

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15548: -- Fix Version/s: 3.7.0 > Send GroupConsumerHeartbeatRequest on Consumer.close() > --

[jira] [Updated] (KAFKA-15696) Revoke partitions on Consumer.close()

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15696: -- Fix Version/s: 3.7.0 > Revoke partitions on Consumer.close() > - >

[jira] [Updated] (KAFKA-15475) Timeout request might retry forever even if the user API times out in PrototypeAsyncConsumer

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15475: -- Parent: (was: KAFKA-14246) Issue Type: Bug (was: Sub-task) > Timeout request might retry

[jira] [Updated] (KAFKA-15866) Refactor OffsetFetchRequestState Error handling to be more consistent with OffsetCommitRequestState

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15866: -- Parent: (was: KAFKA-14246) Issue Type: Improvement (was: Sub-task) > Refactor OffsetFetch

[jira] [Updated] (KAFKA-15652) Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp()

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15652: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Add tests to verify OffsetF

[jira] [Updated] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15639: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Investigate ConsumerNetwork

[jira] [Updated] (KAFKA-15634) Investigate FetcherTest's/FetchRequestManager's testQuotaMetrics

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15634: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Investigate FetcherTest's/F

[jira] [Updated] (KAFKA-15284) Implement ConsumerGroupProtocolVersionResolver to determine consumer group protocol

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15284: -- Parent: (was: KAFKA-14246) Issue Type: New Feature (was: Sub-task) > Implement ConsumerGr

[jira] [Updated] (KAFKA-15615) Improve handling of fetching during metadata updates

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15615: -- Parent: (was: KAFKA-14246) Issue Type: Improvement (was: Sub-task) > Improve handling of

[jira] [Updated] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15558: -- Parent: (was: KAFKA-14246) Issue Type: Task (was: Sub-task) > Determine if Timer should b

[jira] [Updated] (KAFKA-15553) Review committed offset refresh logic

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15553: -- Parent: (was: KAFKA-14246) Issue Type: Task (was: Sub-task) > Review committed offset ref

[jira] [Updated] (KAFKA-15515) Remove duplicated integration tests for new consumer

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15515: -- Component/s: unit tests > Remove duplicated integration tests for new consumer > -

[jira] [Updated] (KAFKA-15515) Remove duplicated integration tests for new consumer

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15515: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Remove duplicated integrati

[jira] [Updated] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15551: -- Parent: (was: KAFKA-14246) Issue Type: Improvement (was: Sub-task) > Evaluate conditions

[jira] [Updated] (KAFKA-15250) DefaultBackgroundThread is running tight loop

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15250: -- Parent: (was: KAFKA-14246) Issue Type: Improvement (was: Sub-task) > DefaultBackgroundThr

[jira] [Updated] (KAFKA-15305) The background thread should try to process the remaining task until the shutdown timer is expired

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15305: -- Parent: (was: KAFKA-14246) Issue Type: Improvement (was: Sub-task) > The background threa

[jira] [Updated] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15556: -- Parent: (was: KAFKA-14246) Issue Type: Improvement (was: Sub-task) > Remove NetworkClient

[jira] [Updated] (KAFKA-15173) Consumer event queues should be bounded

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15173: -- Parent: (was: KAFKA-14246) Issue Type: Improvement (was: Sub-task) > Consumer event queue

[jira] [Updated] (KAFKA-15320) Document event queueing patterns

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15320: -- Parent: (was: KAFKA-14246) Issue Type: Task (was: Sub-task) > Document event queueing pat

[jira] [Updated] (KAFKA-15867) Should ConsumerNetworkThread wrap the exception and notify the polling thread?

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15867: -- Parent: (was: KAFKA-14246) Issue Type: Task (was: Sub-task) > Should ConsumerNetworkThrea

[jira] [Updated] (KAFKA-15942) Implement ConsumerInterceptor

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15942: -- Parent: (was: KAFKA-14246) Issue Type: New Feature (was: Sub-task) > Implement ConsumerIn

[jira] [Updated] (KAFKA-15636) Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15636: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Investigate FetcherTest's/F

[jira] [Updated] (KAFKA-15637) Investigate FetcherTest's/FetchRequestManager's testFetchCompletedBeforeHandlerAdded

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15637: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Investigate FetcherTest's/F

[jira] [Updated] (KAFKA-15635) Investigate FetcherTest's/FetchRequestManager's testFetcherLeadMetric

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15635: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Investigate FetcherTest's/F

[jira] [Updated] (KAFKA-15638) Investigate ConsumerNetworkThreadTest's testPollResultTimer

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15638: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Investigate ConsumerNetwork

[jira] [Updated] (KAFKA-15557) Investigate FetcherTest's/FetchRequestManager's duplicate metadata update in assignFromUserNoId

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15557: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Investigate FetcherTest's/F

[jira] [Updated] (KAFKA-15617) Investigate FetcherTest's/FetchRequestManager's testFetchingPendingPartitions and testInflightFetchOnPendingPartitions overlap

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15617: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Investigate FetcherTest's/F

[jira] [Updated] (KAFKA-15606) Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15606: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Investigate FetcherTest's/F

[jira] [Updated] (KAFKA-15946) AsyncKafkaConsumer should retry commits on the application thread instead of auto-retry

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15946: -- Parent: (was: KAFKA-14246) Issue Type: Improvement (was: Sub-task) > AsyncKafkaConsumer s

[jira] [Updated] (KAFKA-15993) Enable integration tests that relies on rebalance listener

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15993: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Enable integration tests th

[jira] [Updated] (KAFKA-15948) Refactor AsyncKafkaConsumer shutdown

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15948: -- Parent: (was: KAFKA-14246) Issue Type: Improvement (was: Sub-task) > Refactor AsyncKafkaC

[jira] [Updated] (KAFKA-16000) Migrate MembershipManagerImplTest away from ConsumerTestBuilder

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16000: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Migrate MembershipManagerIm

[jira] [Updated] (KAFKA-15872) Investigate autocommit retry logic

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15872: -- Parent: (was: KAFKA-14246) Issue Type: Improvement (was: Sub-task) > Investigate autocomm

[jira] [Updated] (KAFKA-15999) Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15999: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Migrate HeartbeatRequestMan

[jira] [Updated] (KAFKA-16019) Some of the tests in PlaintextConsumer can't seem to deterministically invokes and verify the consumer callback

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16019: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Some of the tests in Plaint

[jira] [Updated] (KAFKA-16022) AsyncKafkaConsumer sometimes complains "No current assignment for partition {}"

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16022: -- Parent: (was: KAFKA-14246) Issue Type: Bug (was: Sub-task) > AsyncKafkaConsumer sometimes

[jira] [Updated] (KAFKA-16001) Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16001: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > Migrate ConsumerNetworkThre

[jira] [Updated] (KAFKA-16023) PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16023: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > PlaintextConsumerTest needs

[jira] [Updated] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16024: -- Parent: (was: KAFKA-14246) Issue Type: Test (was: Sub-task) > SaslPlaintextConsumerTest#t

[jira] [Updated] (KAFKA-15942) Implement ConsumerInterceptor

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15942: -- Fix Version/s: 3.8.0 > Implement ConsumerInterceptor > - > >

[jira] [Updated] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16009: -- Fix Version/s: 3.8.0 > Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation >

[jira] [Updated] (KAFKA-15282) Implement client support for KIP-848 client-side assignors

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15282: -- Fix Version/s: 3.8.0 > Implement client support for KIP-848 client-side assignors > --

[jira] [Updated] (KAFKA-15993) Enable integration tests that relies on rebalance listener

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15993: -- Fix Version/s: 3.8.0 > Enable integration tests that relies on rebalance listener > --

[jira] [Updated] (KAFKA-15283) Add support for topic ID-related Consumer changes

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15283: -- Fix Version/s: 3.8.0 > Add support for topic ID-related Consumer changes > ---

[jira] [Updated] (KAFKA-15475) Timeout request might retry forever even if the user API times out in PrototypeAsyncConsumer

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15475: -- Fix Version/s: 3.8.0 > Timeout request might retry forever even if the user API times out in > Protot

[jira] [Updated] (KAFKA-15279) Implement client support for KIP-848 client-side assigner RPCs

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15279: -- Fix Version/s: 3.8.0 > Implement client support for KIP-848 client-side assigner RPCs > --

[jira] [Updated] (KAFKA-15538) Client support for java regex based subscription

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15538: -- Fix Version/s: 3.8.0 > Client support for java regex based subscription > ---

[jira] [Updated] (KAFKA-15692) New integration tests to ensure full coverage

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15692: -- Fix Version/s: 3.8.0 > New integration tests to ensure full coverage > ---

[jira] [Updated] (KAFKA-16023) PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16023: -- Fix Version/s: 3.8.0 > PlaintextConsumerTest needs to wait for reconciliation to complete before > pr

[jira] [Updated] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15561: -- Fix Version/s: 3.8.0 > Client support for new SubscriptionPattern based subscription > --

[jira] [Updated] (KAFKA-15542) Release member assignments on errors

2023-12-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15542: -- Fix Version/s: 3.8.0 > Release member assignments on errors > > >

  1   2   3   >