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

[ 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

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

[ 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

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

[ 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

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

[ 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()

[ 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

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

[ 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

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

[ 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

[ 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

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

[ 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

[ 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) >

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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) >

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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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 >

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

[ 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-15279) Implement client support for KIP-848 client-side assigner RPCs

[ 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-15692) New integration tests to ensure full coverage

[ 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

[ 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 >

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

[ 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

[ 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 > >

[jira] [Updated] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs

[ https://issues.apache.org/jira/browse/KAFKA-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16008: -- Fix Version/s: 3.8.0 > Fix PlaintextConsumerTest.testMaxPollIntervalMs >

[jira] [Updated] (KAFKA-15325) Integrate topicId in OffsetFetch and OffsetCommit async consumer calls

[ https://issues.apache.org/jira/browse/KAFKA-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15325: -- Fix Version/s: 3.8.0 > Integrate topicId in OffsetFetch and OffsetCommit async consumer calls >

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

[ https://issues.apache.org/jira/browse/KAFKA-15305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15305: -- Fix Version/s: 3.8.0 > The background thread should try to process the remaining task until the >

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

[ https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15173: -- Fix Version/s: 4.0.0 > Consumer event queues should be bounded >

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

[ https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15551: -- Fix Version/s: 4.0.0 > Evaluate conditions for short circuiting consumer API calls >

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

[ https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15515: -- Fix Version/s: 4.0.0 > Remove duplicated integration tests for new consumer >

[jira] [Updated] (KAFKA-15691) Upgrade existing and add new system tests to use new consumer

[ https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15691: -- Fix Version/s: 4.0.0 > Upgrade existing and add new system tests to use new consumer >

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

[ https://issues.apache.org/jira/browse/KAFKA-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15635: -- Fix Version/s: 4.0.0 > Investigate FetcherTest's/FetchRequestManager's testFetcherLeadMetric >

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

[ https://issues.apache.org/jira/browse/KAFKA-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15617: -- Fix Version/s: 4.0.0 > Investigate FetcherTest's/FetchRequestManager's testFetchingPendingPartitions

[jira] [Updated] (KAFKA-15321) Document consumer group member state machine

[ https://issues.apache.org/jira/browse/KAFKA-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15321: -- Fix Version/s: 4.0.0 > Document consumer group member state machine >

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

[ https://issues.apache.org/jira/browse/KAFKA-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15634: -- Fix Version/s: 4.0.0 > Investigate FetcherTest's/FetchRequestManager's testQuotaMetrics >

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

[ https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15615: -- Fix Version/s: 4.0.0 > Improve handling of fetching during metadata updates >

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

[ https://issues.apache.org/jira/browse/KAFKA-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15637: -- Fix Version/s: 4.0.0 > Investigate FetcherTest's/FetchRequestManager's >

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

[ https://issues.apache.org/jira/browse/KAFKA-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15636: -- Fix Version/s: 4.0.0 > Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics >

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

[ https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15320: -- Fix Version/s: 4.0.0 > Document event queueing patterns > > >

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

[ https://issues.apache.org/jira/browse/KAFKA-15606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15606: -- Fix Version/s: 4.0.0 > Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval >

[jira] [Updated] (KAFKA-15818) Implement max poll interval

[ https://issues.apache.org/jira/browse/KAFKA-15818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15818: -- Fix Version/s: 3.7.0 > Implement max poll interval > --- > >

[jira] [Updated] (KAFKA-15456) Add support for OffsetFetch version 9 in consumer

[ https://issues.apache.org/jira/browse/KAFKA-15456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15456: -- Fix Version/s: 3.7.0 > Add support for OffsetFetch version 9 in consumer >

[jira] [Updated] (KAFKA-15588) Purge the unsent offset commits/fetches when the member is fenced/failed

[ https://issues.apache.org/jira/browse/KAFKA-15588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15588: -- Fix Version/s: 3.8.0 > Purge the unsent offset commits/fetches when the member is fenced/failed >

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

[ https://issues.apache.org/jira/browse/KAFKA-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15948: -- Fix Version/s: 3.8.0 > Refactor AsyncKafkaConsumer shutdown > >

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

[ https://issues.apache.org/jira/browse/KAFKA-16019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16019: -- Fix Version/s: 3.8.0 > Some of the tests in PlaintextConsumer can't seem to deterministically >

[jira] [Updated] (KAFKA-15773) Group protocol configuration should be validated

[ https://issues.apache.org/jira/browse/KAFKA-15773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15773: -- Fix Version/s: 3.8.0 > Group protocol configuration should be validated >

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

[ https://issues.apache.org/jira/browse/KAFKA-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15652: -- Fix Version/s: 3.8.0 > Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp() >

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

[ https://issues.apache.org/jira/browse/KAFKA-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16001: -- Fix Version/s: 3.8.0 > Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder >

[jira] [Updated] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose

[ https://issues.apache.org/jira/browse/KAFKA-16011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16011: -- Fix Version/s: 3.8.0 > Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose >

[jira] [Updated] (KAFKA-15455) Add support for OffsetCommit version 9 in consumer

[ https://issues.apache.org/jira/browse/KAFKA-15455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15455: -- Fix Version/s: 3.7.0 > Add support for OffsetCommit version 9 in consumer >

[jira] [Updated] (KAFKA-15846) Review consumer leave group request best effort

[ https://issues.apache.org/jira/browse/KAFKA-15846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15846: -- Fix Version/s: 3.8.0 > Review consumer leave group request best effort >

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

[ https://issues.apache.org/jira/browse/KAFKA-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16024: -- Fix Version/s: 3.8.0 > SaslPlaintextConsumerTest#testCoordinatorFailover is flaky >

[jira] [Updated] (KAFKA-16033) Review retry logic of OffsetFetch and OffsetCommit responses

[ https://issues.apache.org/jira/browse/KAFKA-16033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16033: -- Fix Version/s: 3.8.0 > Review retry logic of OffsetFetch and OffsetCommit responses >

[jira] [Updated] (KAFKA-16004) Review new consumer inflight offset commit logic

[ https://issues.apache.org/jira/browse/KAFKA-16004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16004: -- Fix Version/s: 3.8.0 > Review new consumer inflight offset commit logic >

[jira] [Updated] (KAFKA-15848) Consumer API timeout inconsistent between ConsumerDelegate implementations

[ https://issues.apache.org/jira/browse/KAFKA-15848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15848: -- Fix Version/s: 3.8.0 > Consumer API timeout inconsistent between ConsumerDelegate implementations >

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

[ https://issues.apache.org/jira/browse/KAFKA-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15872: -- Fix Version/s: 3.8.0 > Investigate autocommit retry logic > -- > >

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

[ https://issues.apache.org/jira/browse/KAFKA-15946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15946: -- Fix Version/s: 3.8.0 > AsyncKafkaConsumer should retry commits on the application thread instead of

[jira] [Updated] (KAFKA-15839) Improve TopicIdPartition integration in consumer membershipManager

[ https://issues.apache.org/jira/browse/KAFKA-15839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15839: -- Fix Version/s: 3.8.0 > Improve TopicIdPartition integration in consumer membershipManager >

[jira] [Updated] (KAFKA-15967) Fix revocation in reconcilation logic

[ https://issues.apache.org/jira/browse/KAFKA-15967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15967: -- Fix Version/s: 3.8.0 > Fix revocation in reconcilation logic > -

[jira] [Updated] (KAFKA-15697) Add local assignor and ensure it cannot be used with server side assignor

[ https://issues.apache.org/jira/browse/KAFKA-15697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15697: -- Fix Version/s: 3.8.0 > Add local assignor and ensure it cannot be used with server side assignor >

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

[ https://issues.apache.org/jira/browse/KAFKA-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16010: -- Fix Version/s: 3.8.0 > Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling >

[jira] [Updated] (KAFKA-15832) Trigger client reconciliation based on manager poll

[ https://issues.apache.org/jira/browse/KAFKA-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15832: -- Fix Version/s: 3.8.0 > Trigger client reconciliation based on manager poll >

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

[ https://issues.apache.org/jira/browse/KAFKA-16022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16022: -- Fix Version/s: 3.8.0 > AsyncKafkaConsumer sometimes complains "No current assignment for partition >

[jira] [Updated] (KAFKA-15954) Review minimal effort approach on consumer last heartbeat on unsubscribe

[ https://issues.apache.org/jira/browse/KAFKA-15954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15954: -- Fix Version/s: 3.8.0 > Review minimal effort approach on consumer last heartbeat on unsubscribe >

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

[ https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15638: -- Fix Version/s: 3.8.0 > Investigate ConsumerNetworkThreadTest's testPollResultTimer >

[jira] [Updated] (KAFKA-15835) Group commit/callbacks triggering logic

[ https://issues.apache.org/jira/browse/KAFKA-15835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15835: -- Fix Version/s: 3.8.0 > Group commit/callbacks triggering logic >

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

[ https://issues.apache.org/jira/browse/KAFKA-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15867: -- Fix Version/s: 3.8.0 > Should ConsumerNetworkThread wrap the exception and notify the polling thread?

[jira] [Updated] (KAFKA-15974) Enforce that CompletableApplicationEvent has a timeout that is respected

[ https://issues.apache.org/jira/browse/KAFKA-15974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15974: -- Fix Version/s: 3.8.0 > Enforce that CompletableApplicationEvent has a timeout that is respected >

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

[ https://issues.apache.org/jira/browse/KAFKA-16000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16000: -- Fix Version/s: 3.8.0 > Migrate MembershipManagerImplTest away from ConsumerTestBuilder >

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

[ https://issues.apache.org/jira/browse/KAFKA-15999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15999: -- Fix Version/s: 3.8.0 > Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder >

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

[ https://issues.apache.org/jira/browse/KAFKA-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15553: -- Fix Version/s: 3.8.0 > Review committed offset refresh logic > -

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

[ https://issues.apache.org/jira/browse/KAFKA-15866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15866: -- Fix Version/s: 3.8.0 > Refactor OffsetFetchRequestState Error handling to be more consistent with >

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

[ https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15284: -- Fix Version/s: 3.8.0 > Implement ConsumerGroupProtocolVersionResolver to determine consumer group >

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

[ https://issues.apache.org/jira/browse/KAFKA-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15557: -- Fix Version/s: 3.8.0 > Investigate FetcherTest's/FetchRequestManager's duplicate metadata update in

[jira] [Updated] (KAFKA-16032) Review inconsistent error handling of OffsetFetch and OffsetCommit responses

[ https://issues.apache.org/jira/browse/KAFKA-16032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16032: -- Fix Version/s: 3.8.0 > Review inconsistent error handling of OffsetFetch and OffsetCommit responses >

[jira] [Updated] (KAFKA-15843) Review consumer onPartitionsAssigned called with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15843: -- Fix Version/s: 3.8.0 > Review consumer onPartitionsAssigned called with empty partitions >

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

[ https://issues.apache.org/jira/browse/KAFKA-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15639: -- Fix Version/s: 3.8.0 > Investigate ConsumerNetworkThreadTest's >

[jira] [Updated] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs

[ https://issues.apache.org/jira/browse/KAFKA-16029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16029: -- Fix Version/s: 3.8.0 > Investigate cause of "Unable to find FetchSessionHandler for node X" in logs >

<    6   7   8   9   10   11   12   13   14   15   >