[jira] [Updated] (KAFKA-16169) FencedException in commitAsync not propagated without callback

[ https://issues.apache.org/jira/browse/KAFKA-16169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16169: -- Priority: Critical (was: Major) > FencedException in commitAsync not propagated without callback >

[jira] [Updated] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup

[ https://issues.apache.org/jira/browse/KAFKA-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16167: -- Priority: Critical (was: Major) > Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup >

[jira] [Updated] (KAFKA-16190) Member should send full heartbeat when rejoining

[ https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16190: -- Priority: Critical (was: Major) > Member should send full heartbeat when rejoining >

[jira] [Updated] (KAFKA-16109) Ensure system tests cover the "simple consumer + commit" use case

[ https://issues.apache.org/jira/browse/KAFKA-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16109: -- Fix Version/s: 4.0.0 (was: 3.8.0) > Ensure system tests cover the "simple

[jira] [Commented] (KAFKA-16110) Implement consumer performance tests

[ https://issues.apache.org/jira/browse/KAFKA-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814501#comment-17814501 ] Kirk True commented on KAFKA-16110: --- Yes, we can use Trogdor for some _basic_ performance numbers.

[jira] [Updated] (KAFKA-16110) Implement consumer performance tests

[ https://issues.apache.org/jira/browse/KAFKA-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16110: -- Fix Version/s: 4.0.0 (was: 3.8.0) > Implement consumer performance tests >

[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: -- Priority: Minor (was: Major) > Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder >

[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: -- Priority: Minor (was: Major) > Migrate MembershipManagerImplTest away from ConsumerTestBuilder >

[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: -- Priority: Minor (was: Major) > Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder >

[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: -- Priority: Minor (was: Major) > Remove NetworkClientDelegate methods isUnavailable,

[jira] [Updated] (KAFKA-16142) Update metrics documentation for errors and new metrics

[ https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16142: -- Priority: Minor (was: Major) > Update metrics documentation for errors and new metrics >

[jira] [Updated] (KAFKA-16142) Update metrics documentation for errors and new metrics

[ https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16142: -- Description: What is the documentation to update here? AFAIUI, we're not changing or adding metrics

[jira] [Updated] (KAFKA-16142) Update metrics documentation for errors and new metrics

[ https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16142: -- Priority: Major (was: Critical) > Update metrics documentation for errors and new metrics >

[jira] [Updated] (KAFKA-16133) Commits during reconciliation always time out

[ https://issues.apache.org/jira/browse/KAFKA-16133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16133: -- Priority: Critical (was: Major) > Commits during reconciliation always time out >

[jira] [Updated] (KAFKA-15970) KIP-951, port newly added tests in FetcherTest.java to FetchRequestManagerTest.ajva

[ https://issues.apache.org/jira/browse/KAFKA-15970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15970: -- Labels: kip-951 (was: ) > KIP-951, port newly added tests in FetcherTest.java to >

[jira] [Updated] (KAFKA-15283) Client support for OffsetFetch and OffsetCommit with topic ID

[ 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: 4.0.0 (was: 3.8.0) > Client support for OffsetFetch and

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

[ https://issues.apache.org/jira/browse/KAFKA-15846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15846: -- Priority: Critical (was: Major) > Review consumer leave group request best effort and response

[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: -- Priority: Critical (was: Major) > Integrate topicId in OffsetFetch and OffsetCommit async consumer

[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: -- Priority: Critical (was: Major) > Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose >

[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: -- Priority: Critical (was: Major) > Trigger client reconciliation based on manager poll >

[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: -- Priority: Critical (was: Major) > Refactor AsyncKafkaConsumer shutdown >

[jira] [Updated] (KAFKA-16032) Review client errors thrown on OffsetFetch and OffsetCommit failures

[ https://issues.apache.org/jira/browse/KAFKA-16032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16032: -- Priority: Critical (was: Major) > Review client errors thrown on OffsetFetch and OffsetCommit

[jira] [Updated] (KAFKA-16203) AutoCommit of empty offsets blocks following requests due to inflight flag

[ https://issues.apache.org/jira/browse/KAFKA-16203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16203: -- Priority: Critical (was: Major) > AutoCommit of empty offsets blocks following requests due to

[jira] [Updated] (KAFKA-16033) Review client 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: -- Priority: Critical (was: Major) > Review client retry logic of OffsetFetch and OffsetCommit

[jira] [Updated] (KAFKA-16107) Ensure consumer does not start fetching from added partitions until onPartitionsAssigned completes

[ https://issues.apache.org/jira/browse/KAFKA-16107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16107: -- Priority: Critical (was: Major) > Ensure consumer does not start fetching from added partitions

[jira] [Updated] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned

[ https://issues.apache.org/jira/browse/KAFKA-16194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16194: -- Priority: Critical (was: Major) > KafkaConsumer.groupMetadata() should be correct when first records

[jira] [Updated] (KAFKA-16215) Consumer does not rejoin after fenced on delayed revocation

[ https://issues.apache.org/jira/browse/KAFKA-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16215: -- Priority: Critical (was: Major) > Consumer does not rejoin after fenced on delayed revocation >

[jira] [Updated] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios

[ https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16111: -- Labels: callback consumer-threading-refactor integration-tests (was: callback

[jira] [Updated] (KAFKA-15270) Integration tests for AsyncConsumer simple consume case

[ https://issues.apache.org/jira/browse/KAFKA-15270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15270: -- Labels: consumer-threading-refactor integration-tests (was: consumer-threading-refactor

[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: -- Priority: Blocker (was: Major) > Implement ConsumerInterceptor > - > >

[jira] [Updated] (KAFKA-16151) Fix PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe

[ https://issues.apache.org/jira/browse/KAFKA-16151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16151: -- Priority: Critical (was: Major) > Fix

[jira] [Updated] (KAFKA-16104) Enable additional PlaintextConsumerTest tests for new consumer

[ https://issues.apache.org/jira/browse/KAFKA-16104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16104: -- Priority: Critical (was: Minor) > Enable additional PlaintextConsumerTest tests for new consumer >

[jira] [Updated] (KAFKA-16150) Fix PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe

[ https://issues.apache.org/jira/browse/KAFKA-16150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16150: -- Priority: Critical (was: Major) > Fix

[jira] [Updated] (KAFKA-16217) Transactional producer stuck in IllegalStateException during close

[ https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16217: -- Fix Version/s: 3.6.2 3.7.1 > Transactional producer stuck in IllegalStateException

[jira] [Updated] (KAFKA-16217) Transactional producer stuck in IllegalStateException during close

[ https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16217: -- Labels: transactions (was: ) > Transactional producer stuck in IllegalStateException during close >

[jira] [Assigned] (KAFKA-16217) Transactional producer stuck in IllegalStateException during close

[ https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16217: - Assignee: Kirk True > Transactional producer stuck in IllegalStateException during close >

[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: -- Priority: Critical (was: Major) > Client support for new SubscriptionPattern based subscription >

[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: -- Priority: Critical (was: Major) > Client support for java regex based subscription >

[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: -- Priority: Major (was: Blocker) > Implement ConsumerGroupProtocolVersionResolver to determine

[jira] [Resolved] (KAFKA-15691) 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 resolved KAFKA-15691. --- Resolution: Duplicate > Add new system tests to use new consumer >

[jira] [Updated] (KAFKA-16169) FencedException in commitAsync not propagated without callback

[ https://issues.apache.org/jira/browse/KAFKA-16169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16169: -- Labels: kip-848-client-support (was: ) > FencedException in commitAsync not propagated without

[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: -- Labels: flaky-test integration-tests (was: flaky-test) >

[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: -- Component/s: (was: unit tests) > SaslPlaintextConsumerTest#testCoordinatorFailover is flaky >

[jira] [Updated] (KAFKA-15993) Enable max poll integration tests that depend on callback invocation

[ https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15993: -- Labels: consumer-threading-refactor integration-tests timeout (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-16112) Review JMX metrics in Async Consumer and determine the missing ones

[ https://issues.apache.org/jira/browse/KAFKA-16112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16112: -- Issue Type: Task (was: Improvement) > Review JMX metrics in Async Consumer and determine the missing

[jira] [Updated] (KAFKA-16142) Update metrics documentation for errors and new metrics

[ https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16142: -- Issue Type: Improvement (was: Task) Priority: Critical (was: Major) > Update metrics

[jira] [Updated] (KAFKA-16112) Review JMX metrics in Async Consumer and determine the missing ones

[ https://issues.apache.org/jira/browse/KAFKA-16112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16112: -- Issue Type: Improvement (was: Task) Priority: Critical (was: Major) > Review JMX metrics in

[jira] [Updated] (KAFKA-16113) AsyncKafkaConsumer: Add missing offset commit metrics

[ https://issues.apache.org/jira/browse/KAFKA-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16113: -- Priority: Critical (was: Major) > AsyncKafkaConsumer: Add missing offset commit metrics >

[jira] [Updated] (KAFKA-16116) AsyncKafkaConsumer: Add missing rebalance metrics

[ https://issues.apache.org/jira/browse/KAFKA-16116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16116: -- Priority: Critical (was: Major) > AsyncKafkaConsumer: Add missing rebalance metrics >

[jira] [Updated] (KAFKA-16115) AsyncKafkaConsumer: Add missing heartbeat metrics

[ https://issues.apache.org/jira/browse/KAFKA-16115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16115: -- Priority: Critical (was: Major) > AsyncKafkaConsumer: Add missing heartbeat metrics >

[jira] [Updated] (KAFKA-16143) New metrics for KIP-848 protocol

[ https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16143: -- Fix Version/s: 4.0.0 (was: 3.8.0) > New metrics for KIP-848 protocol >

[jira] [Updated] (KAFKA-16143) New metrics for KIP-848 protocol

[ https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16143: -- Labels: kip-848-client-support metrics needs-kip (was: kip-848-client-support metrics) > New

[jira] [Updated] (KAFKA-16143) New metrics for KIP-848 protocol

[ https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16143: -- Issue Type: Improvement (was: Task) > New metrics for KIP-848 protocol >

[jira] [Updated] (KAFKA-16143) New metrics for KIP-848 protocol

[ https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16143: -- Description: This task is to consider what _new_ metrics we need from the KIP-848 protocol that

[jira] [Updated] (KAFKA-16202) Extra dot in error message in producer

[ https://issues.apache.org/jira/browse/KAFKA-16202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16202: -- Component/s: clients producer > Extra dot in error message in producer >

[jira] [Commented] (KAFKA-16215) Consumer does not rejoin after fenced on delayed revocation

[ https://issues.apache.org/jira/browse/KAFKA-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813382#comment-17813382 ] Kirk True commented on KAFKA-16215: --- [~lianetm] do we want this in 3.8.0? > Consumer does not rejoin

[jira] [Updated] (KAFKA-16156) System test failing for new consumer on endOffsets with negative timestamps

[ https://issues.apache.org/jira/browse/KAFKA-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16156: -- Component/s: system tests > System test failing for new consumer on endOffsets with negative

[jira] [Updated] (KAFKA-16156) System test failing for new consumer on endOffsets with negative timestamps

[ https://issues.apache.org/jira/browse/KAFKA-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16156: -- Labels: consumer-threading-refactor kip-848-client-support system-tests (was:

[jira] [Updated] (KAFKA-16115) AsyncKafkaConsumer: Add missing heartbeat metrics

[ https://issues.apache.org/jira/browse/KAFKA-16115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16115: -- Labels: consumer-threading-refactor metrics (was: consumer-threading-refactor) >

[jira] [Updated] (KAFKA-16112) Review JMX metrics in Async Consumer and determine the missing ones

[ https://issues.apache.org/jira/browse/KAFKA-16112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16112: -- Labels: consumer-threading-refactor metrics (was: consumer-threading-refactor) > Review JMX metrics

[jira] [Updated] (KAFKA-16113) AsyncKafkaConsumer: Add missing offset commit metrics

[ https://issues.apache.org/jira/browse/KAFKA-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16113: -- Labels: consumer-threading-refactor metrics (was: consumer-threading-refactor) >

[jira] [Updated] (KAFKA-16142) Update metrics documentation for errors and new metrics

[ https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16142: -- Labels: consumer-threading-refactor metrics (was: consumer-threading-refactor) > Update metrics

[jira] [Updated] (KAFKA-16116) AsyncKafkaConsumer: Add missing rebalance metrics

[ https://issues.apache.org/jira/browse/KAFKA-16116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16116: -- Labels: consumer-threading-refactor metrics (was: consumer-threading-refactor) >

[jira] [Updated] (KAFKA-16143) New metrics for KIP-848 protocol

[ https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16143: -- Labels: kip-848-client-support metrics (was: kip-848-client-support) > New metrics for KIP-848

[jira] [Updated] (KAFKA-16109) Ensure system tests cover the "simple consumer + commit" use case

[ https://issues.apache.org/jira/browse/KAFKA-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16109: -- Component/s: system tests > Ensure system tests cover the "simple consumer + commit" use case >

[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: -- Labels: consumer-threading-refactor fetcher unit-tests (was: consumer-threading-refactor fetcher) >

[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: -- Labels: consumer-threading-refactor fetcher unit-tests (was: consumer-threading-refactor fetcher) >

[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: -- Labels: consumer-threading-refactor fetcher unit-tests (was: consumer-threading-refactor fetcher) >

[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: -- Labels: consumer-threading-refactor unit-tests (was: consumer-threading-refactor) > Migrate

[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: -- Labels: consumer-threading-refactor fetcher unit-tests (was: consumer-threading-refactor fetcher) >

[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: -- Labels: consumer-threading-refactor unit-tests (was: consumer-threading-refactor) > Investigate

[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: -- Labels: consumer-threading-refactor position unit-tests (was: consumer-threading-refactor position)

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

[ https://issues.apache.org/jira/browse/KAFKA-15991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15991: -- Labels: consumer-threading-refactor flaky-test kip-848-client-support unit-tests (was:

[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: -- Labels: consumer-threading-refactor unit-tests (was: consumer-threading-refactor) > Migrate

[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: -- Labels: consumer-threading-refactor unit-tests (was: consumer-threading-refactor) > Investigate

[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: -- Labels: consumer-threading-refactor unit-tests (was: consumer-threading-refactor) > Migrate

[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: -- Labels: consumer-threading-refactor fetcher unit-tests (was: consumer-threading-refactor fetcher) >

[jira] [Updated] (KAFKA-14724) Port tests in FetcherTest to FetchRequestManagerTest

[ https://issues.apache.org/jira/browse/KAFKA-14724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14724: -- Labels: consumer-threading-refactor fetcher kip-848-e2e kip-848-preview unit-tests (was:

[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: -- Labels: consumer-threading-refactor fetcher unit-tests (was: consumer-threading-refactor fetcher) >

[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: -- Labels: consumer-threading-refactor fetcher unit-tests (was: consumer-threading-refactor fetcher) >

[jira] [Updated] (KAFKA-15971) Re-enable consumer integration tests for new consumer

[ https://issues.apache.org/jira/browse/KAFKA-15971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15971: -- Component/s: (was: unit tests) > Re-enable consumer integration tests for new consumer >

[jira] [Updated] (KAFKA-15971) Re-enable consumer integration tests for new consumer

[ https://issues.apache.org/jira/browse/KAFKA-15971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15971: -- Labels: consumer-threading-refactor integration-tests kip-848 kip-848-preview (was:

[jira] [Updated] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer")

[ https://issues.apache.org/jira/browse/KAFKA-15932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15932: -- Labels: consumer-threading-refactor flaky-test integration-tests kip-848-client-support (was:

[jira] [Updated] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer")

[ https://issues.apache.org/jira/browse/KAFKA-15932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15932: -- Labels: consumer-threading-refactor flaky-test integration-tests kip-848 kip-848-client-support

[jira] [Updated] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer")

[ https://issues.apache.org/jira/browse/KAFKA-15932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15932: -- Component/s: (was: unit tests) > Flaky test -

[jira] [Updated] (KAFKA-15986) New consumer group protocol integration test failures

[ https://issues.apache.org/jira/browse/KAFKA-15986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15986: -- Component/s: (was: unit tests) > New consumer group protocol integration test failures >

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

[ https://issues.apache.org/jira/browse/KAFKA-15991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15991: -- Labels: consumer-threading-refactor flaky-test kip-848-client-support (was:

[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: (was: unit tests) > Remove duplicated integration tests for new consumer >

[jira] [Updated] (KAFKA-15986) New consumer group protocol integration test failures

[ https://issues.apache.org/jira/browse/KAFKA-15986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15986: -- Labels: consumer-threading-refactor integration-tests kip-848 kip-848-client-support (was:

[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: -- Labels: consumer-threading-refactor integration-tests (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup

[ https://issues.apache.org/jira/browse/KAFKA-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16167: -- Labels: consumer-threading-refactor integration-tests kip-848-client-support (was:

[jira] [Updated] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup

[ https://issues.apache.org/jira/browse/KAFKA-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16167: -- Component/s: (was: unit tests) > Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup >

[jira] [Updated] (KAFKA-16109) Ensure system tests cover the "simple consumer + commit" use case

[ https://issues.apache.org/jira/browse/KAFKA-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16109: -- Component/s: (was: system tests) > Ensure system tests cover the "simple consumer + commit" use

[jira] [Updated] (KAFKA-16109) Ensure system tests cover the "simple consumer + commit" use case

[ https://issues.apache.org/jira/browse/KAFKA-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16109: -- Labels: consumer-threading-refactor system-tests (was: consumer-threading-refactor) > Ensure system

[jira] [Updated] (KAFKA-16104) Enable additional PlaintextConsumerTest tests for new consumer

[ https://issues.apache.org/jira/browse/KAFKA-16104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16104: -- Component/s: (was: system tests) Labels: consumer-threading-refactor integration-tests

[jira] [Updated] (KAFKA-15993) Enable max poll integration tests that depend on callback invocation

[ https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15993: -- Component/s: (was: system tests) Labels: consumer-threading-refactor integration-tests

[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: -- Component/s: (was: system tests) Labels: consumer-threading-refactor integration-tests

[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: -- Component/s: (was: system tests) Labels: consumer-threading-refactor integration-tests

[jira] [Updated] (KAFKA-16019) Some of the tests in PlaintextConsumer can't seem to deterministically invoke 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: -- Component/s: (was: system tests) Labels: consumer-threading-refactor integration-tests

[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: -- Component/s: (was: system tests) Labels: consumer-threading-refactor integration-tests

<    1   2   3   4   5   6   7   8   9   10   >