[jira] [Updated] (KAFKA-17013) RequestManager#ConnectionState#toString() should use %s

[ https://issues.apache.org/jira/browse/KAFKA-17013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17013: -- Labels: (was: consumer-threading-refactor) > RequestManager#ConnectionState#toString() should use %s

[jira] [Updated] (KAFKA-17013) RequestManager#ConnectionState#toString() should use %s

[ https://issues.apache.org/jira/browse/KAFKA-17013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17013: -- Labels: consumer-threading-refactor (was: ) > RequestManager#ConnectionState#toString() should use %s

[jira] [Updated] (KAFKA-17013) RequestManager#ConnectionState#toString() should use %s

[ https://issues.apache.org/jira/browse/KAFKA-17013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17013: -- Component/s: clients consumer > RequestManager#ConnectionState#toString() should use

[jira] [Updated] (KAFKA-16942) Use ConcurrentHashMap in RecordAccumulator#nodeStats

[ https://issues.apache.org/jira/browse/KAFKA-16942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16942: -- Component/s: producer > Use ConcurrentHashMap in RecordAccumulator#nodeStats > --

[jira] [Updated] (KAFKA-16957) Enable KafkaConsumerTest#configurableObjectsShouldSeeGeneratedClientId to work with CLASSIC and CONSUMER

[ https://issues.apache.org/jira/browse/KAFKA-16957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16957: -- Fix Version/s: 3.9.0 > Enable KafkaConsumerTest#configurableObjectsShouldSeeGeneratedClientId to > wo

[jira] [Updated] (KAFKA-16957) Enable KafkaConsumerTest#configurableObjectsShouldSeeGeneratedClientId to work with CLASSIC and CONSUMER

[ https://issues.apache.org/jira/browse/KAFKA-16957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16957: -- Component/s: clients consumer unit tests > Enable KafkaConsumerTest#

[jira] [Updated] (KAFKA-16986) After upgrading to Kafka 3.4.1, the producer constantly produces logs related to topicId changes

[ https://issues.apache.org/jira/browse/KAFKA-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16986: -- Component/s: producer > After upgrading to Kafka 3.4.1, the producer constantly produces logs related

[jira] [Updated] (KAFKA-16985) Ensure consumer sends leave request on close even if interrupted

[ https://issues.apache.org/jira/browse/KAFKA-16985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16985: -- Fix Version/s: 3.9.0 > Ensure consumer sends leave request on close even if interrupted >

[jira] [Updated] (KAFKA-16985) Ensure consumer sends leave request on close even if interrupted

[ https://issues.apache.org/jira/browse/KAFKA-16985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16985: -- Component/s: clients consumer > Ensure consumer sends leave request on close even if

[jira] [Updated] (KAFKA-16442) Update streams_standby_replica_test.py to support KIP-848’s group protocol config

[ https://issues.apache.org/jira/browse/KAFKA-16442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16442: -- Fix Version/s: 4.0.0 (was: 3.9.0) > Update streams_standby_replica_test.py to s

[jira] [Updated] (KAFKA-16443) Update streams_static_membership_test.py to support KIP-848’s group protocol config

[ https://issues.apache.org/jira/browse/KAFKA-16443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16443: -- Fix Version/s: 4.0.0 (was: 3.9.0) > Update streams_static_membership_test.py to

[jira] [Updated] (KAFKA-16441) Update streams_broker_down_resilience_test.py to support KIP-848’s group protocol config

[ https://issues.apache.org/jira/browse/KAFKA-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16441: -- Fix Version/s: 4.0.0 (was: 3.9.0) > Update streams_broker_down_resilience_test.

[jira] [Updated] (KAFKA-16315) Investigate propagating metadata updates via queues

[ https://issues.apache.org/jira/browse/KAFKA-16315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16315: -- Fix Version/s: (was: 4.0.0) > Investigate propagating metadata updates via queues > --

[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: (was: 4.0.0) > Add local assignor and ensure it cannot be used with server side ass

[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: (was: 4.0.0) > Review consumer onPartitionsAssigned called with empty partitions >

[jira] [Updated] (KAFKA-15847) Consider partial metadata requests for client reconciliation

[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15847: -- Fix Version/s: (was: 4.0.0) > Consider partial metadata requests for client reconciliation > -

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

[jira] [Updated] (KAFKA-15839) Topic ID integration in consumer subscription state

[ 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: (was: 4.0.0) > Topic ID integration in consumer subscription state > --

[jira] [Updated] (KAFKA-15847) Consider partial metadata requests for client reconciliation

[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15847: -- Fix Version/s: 3.9.0 > Consider partial metadata requests for client reconciliation >

[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.9.0 > Add local assignor and ensure it cannot be used with server side assignor > ---

[jira] [Updated] (KAFKA-16315) Investigate propagating metadata updates via queues

[ https://issues.apache.org/jira/browse/KAFKA-16315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16315: -- Fix Version/s: 3.9.0 > Investigate propagating metadata updates via queues > -

[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.9.0 > Client support for new SubscriptionPattern based subscription > ---

[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.9.0 > Review consumer onPartitionsAssigned called with empty partitions > ---

[jira] [Updated] (KAFKA-15839) Topic ID integration in consumer subscription state

[ 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.9.0 > Topic ID integration in consumer subscription state > -

[jira] [Updated] (KAFKA-16290) Investigate propagating subscription state updates via queues

[ https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16290: -- Fix Version/s: 3.9.0 (was: 4.0.0) > Investigate propagating subscription state

[jira] [Updated] (KAFKA-16290) Investigate propagating subscription state updates via queues

[ https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16290: -- Priority: Critical (was: Major) > Investigate propagating subscription state updates via queues > ---

[jira] [Assigned] (KAFKA-16290) Investigate propagating subscription state updates via queues

[ https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16290: - Assignee: Kirk True (was: Bruno Cadonna) > Investigate propagating subscription state updates

[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 > Client support for OffsetFetch and OffsetCommit with topic ID > ---

[jira] [Assigned] (KAFKA-16390) consume_bench_test.py failed using AsyncKafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16390: - Assignee: Kirk True > consume_bench_test.py failed using AsyncKafkaConsumer > -

[jira] [Updated] (KAFKA-16816) Remove unneeded FencedInstanceId support on commit path for new consumer

[ https://issues.apache.org/jira/browse/KAFKA-16816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16816: -- Fix Version/s: 3.9.0 > Remove unneeded FencedInstanceId support on commit path for new consumer >

[jira] [Updated] (KAFKA-16799) NetworkClientDelegate is not backing off if the node is not found

[ https://issues.apache.org/jira/browse/KAFKA-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16799: -- Fix Version/s: 3.9.0 > NetworkClientDelegate is not backing off if the node is not found > ---

[jira] [Assigned] (KAFKA-15402) Performance regression on close consumer after upgrading to 3.5.0

[ https://issues.apache.org/jira/browse/KAFKA-15402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15402: - Assignee: Kirk True > Performance regression on close consumer after upgrading to 3.5.0 > -

[jira] [Updated] (KAFKA-15402) Performance regression on close consumer after upgrading to 3.5.0

[ https://issues.apache.org/jira/browse/KAFKA-15402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15402: -- Fix Version/s: 3.9.0 > Performance regression on close consumer after upgrading to 3.5.0 > ---

[jira] [Updated] (KAFKA-16819) CoordinatorRequestManager seems to return 0ms during the coordinator discovery

[ https://issues.apache.org/jira/browse/KAFKA-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16819: -- Fix Version/s: 3.9.0 > CoordinatorRequestManager seems to return 0ms during the coordinator discovery

[jira] [Updated] (KAFKA-16984) New consumer should wait for leave group response to avoid responses to disconnected clients

[ https://issues.apache.org/jira/browse/KAFKA-16984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16984: -- Component/s: clients > New consumer should wait for leave group response to avoid responses to > disc

[jira] [Resolved] (KAFKA-16777) New consumer should throw NoOffsetForPartitionException on continuous poll zero if no reset strategy

[ https://issues.apache.org/jira/browse/KAFKA-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16777. --- Reviewer: Bruno Cadonna Resolution: Fixed Resolved as part of fix for KAFKA-16637. > New cons

[jira] [Commented] (KAFKA-16637) AsyncKafkaConsumer removes offset fetch responses from cache too aggressively

[ https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855235#comment-17855235 ] Kirk True commented on KAFKA-16637: --- Thank you [~chia7712]! > AsyncKafkaConsumer remo

[jira] [Updated] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16792: -- Parent: (was: KAFKA-16637) Issue Type: Test (was: Sub-task) > Enable consumer unit tests

[jira] [Updated] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16792: -- Component/s: unit tests > Enable consumer unit tests that fail to fetch offsets only for new consumer

[jira] [Updated] (KAFKA-16966) Allow offset commit fetch to reuse previous request if partitions are a subset

[ https://issues.apache.org/jira/browse/KAFKA-16966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16966: -- Description: In {{{}initWithCommittedOffsetsIfNeeded{}}}, the behavior of the existing {{LegacyKafkaC

[jira] [Created] (KAFKA-16966) Allow offset commit fetch to reuse previous request if partitions are a subset

Kirk True created KAFKA-16966: - Summary: Allow offset commit fetch to reuse previous request if partitions are a subset Key: KAFKA-16966 URL: https://issues.apache.org/jira/browse/KAFKA-16966 Project: Kaf

[jira] [Updated] (KAFKA-16954) Move consumer leave operations on close to background thread

[ https://issues.apache.org/jira/browse/KAFKA-16954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16954: -- Component/s: clients consumer > Move consumer leave operations on close to background

[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.9.0 (was: 3.8.0) > Migrate MembershipManagerImplTest away from

[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.9.0 (was: 3.8.0) > Should ConsumerNetworkThread wrap the excep

[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.9.0 (was: 3.8.0) > AsyncKafkaConsumer sometimes complains “No

[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.9.0 (was: 3.8.0) > Investigate ConsumerNetworkThreadTest's tes

[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: 3.9.0 (was: 3.8.0) > Evaluate conditions for short circuiting co

[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: 3.9.0 (was: 3.8.0) > Document consumer group member state machin

[jira] [Updated] (KAFKA-15767) Redesign TransactionManager to avoid use of ThreadLocal

[ https://issues.apache.org/jira/browse/KAFKA-15767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15767: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Redesign TransactionManager to avoid use of

[jira] [Updated] (KAFKA-16818) Move event processing-related tests from ConsumerNetworkThreadTest to ApplicationEventProcessorTest

[ https://issues.apache.org/jira/browse/KAFKA-16818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16818: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Move event processing-related tests from Co

[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.9.0 (was: 3.8.0) > Group protocol configuration should be vali

[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: 3.9.0 (was: 3.8.0) > Consumer event queues should be bounded > -

[jira] [Updated] (KAFKA-16233) Review auto-commit continuously committing when no progress

[ https://issues.apache.org/jira/browse/KAFKA-16233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16233: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Review auto-commit continuously committing

[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.9.0 (was: 3.8.0) > Migrate HeartbeatRequestManagerTest away fr

[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: 3.9.0 (was: 3.8.0) > Document event queueing patterns >

[jira] [Updated] (KAFKA-16272) Update connect_distributed_test.py to support KIP-848’s group protocol config

[ https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16272: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Update connect_distributed_test.py to suppo

[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: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Update metrics documentation for errors and

[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: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Implement tests for tricky rebalance callba

[jira] [Updated] (KAFKA-16558) Implement HeartbeatRequestState.toStringBase()

[ https://issues.apache.org/jira/browse/KAFKA-16558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16558: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Implement HeartbeatRequestState.toStringBas

[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.9.0 (was: 3.8.0) > Group commit/callbacks triggering logic > -

[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.9.0 (was: 3.8.0) > SaslPlaintextConsumerTest#testCoordinatorFa

[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.9.0 (was: 3.8.0) > Investigate ConsumerNetworkThreadTest's >

[jira] [Updated] (KAFKA-16301) Review fenced member unsubscribe/subscribe callbacks interaction

[ https://issues.apache.org/jira/browse/KAFKA-16301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16301: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Review fenced member unsubscribe/subscribe

[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.9.0 (was: 3.8.0) > Review minimal effort approach on consumer

[jira] [Updated] (KAFKA-16623) KafkaAsyncConsumer system tests warn about revoking partitions that weren't previously assigned

[ https://issues.apache.org/jira/browse/KAFKA-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16623: -- Fix Version/s: 3.9.0 (was: 3.8.0) > KafkaAsyncConsumer system tests warn about

[jira] [Updated] (KAFKA-16255) AsyncKafkaConsumer should not use partition.assignment.strategy

[ https://issues.apache.org/jira/browse/KAFKA-16255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16255: -- Fix Version/s: 3.9.0 (was: 3.8.0) > AsyncKafkaConsumer should not use partition

[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: 3.9.0 (was: 3.8.0) > Improve handling of fetching during metadat

[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: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Remove NetworkClientDelegate methods isUnav

[jira] [Updated] (KAFKA-15553) Review consumer positions update

[ 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.9.0 (was: 3.8.0) > Review consumer positions update >

[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.9.0 (was: 3.8.0) > Migrate ConsumerNetworkThreadTest away from

[jira] [Updated] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying

[ https://issues.apache.org/jira/browse/KAFKA-14945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14945: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Add Serializer#serializeToByteBuffer() to r

[jira] [Updated] (KAFKA-16557) Fix OffsetFetchRequestState.toString()

[ https://issues.apache.org/jira/browse/KAFKA-16557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16557: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Fix OffsetFetchRequestState.toString() > --

[jira] [Updated] (KAFKA-16444) Run KIP-848 unit tests under code coverage

[ https://issues.apache.org/jira/browse/KAFKA-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16444: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Run KIP-848 unit tests under code coverage

[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.9.0 (was: 3.8.0) > Purge the unsent offset commits/fetches whe

[jira] [Updated] (KAFKA-16642) Update KafkaConsumerTest to show parameters in test lists

[ https://issues.apache.org/jira/browse/KAFKA-16642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16642: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Update KafkaConsumerTest to show parameters

[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.9.0 (was: 3.8.0) > Add tests to verify OffsetFetcherUtils.getO

[jira] [Updated] (KAFKA-16576) New consumer fails with assert in consumer_test.py’s test_consumer_failure system test

[ https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16576: -- Fix Version/s: 3.9.0 (was: 3.8.0) > New consumer fails with assert in consumer_

[jira] [Updated] (KAFKA-16256) Update ConsumerConfig to validate use of group.remote.assignor and partition.assignment.strategy based on group.protocol

[ https://issues.apache.org/jira/browse/KAFKA-16256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16256: -- Priority: Blocker (was: Minor) > Update ConsumerConfig to validate use of group.remote.assignor and

[jira] [Updated] (KAFKA-16256) Update ConsumerConfig to validate use of group.remote.assignor and partition.assignment.strategy based on group.protocol

[ https://issues.apache.org/jira/browse/KAFKA-16256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16256: -- Fix Version/s: 4.0.0 (was: 3.8.0) > Update ConsumerConfig to validate use of gr

[jira] [Updated] (KAFKA-16933) New consumer leave group flow may not send leave request and clear epoch

[ https://issues.apache.org/jira/browse/KAFKA-16933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16933: -- Component/s: clients > New consumer leave group flow may not send leave request and clear epoch >

[jira] [Comment Edited] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850215#comment-17850215 ] Kirk True edited comment on KAFKA-16792 at 6/7/24 10:58 PM:

[jira] [Commented] (KAFKA-16899) Rename MembershipManagerImpl's rebalanceTimeoutMs for clarity

[ https://issues.apache.org/jira/browse/KAFKA-16899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852599#comment-17852599 ] Kirk True commented on KAFKA-16899: --- [~linu]—you're welcome to take it. Thanks! > Ren

[jira] [Created] (KAFKA-16899) Rename MembershipManagerImpl's rebalanceTimeoutMs for clarity

Kirk True created KAFKA-16899: - Summary: Rename MembershipManagerImpl's rebalanceTimeoutMs for clarity Key: KAFKA-16899 URL: https://issues.apache.org/jira/browse/KAFKA-16899 Project: Kafka Issu

[jira] [Updated] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16792: -- Description: Enable the following unit tests for the new async consumer in KafkaConsumerTest: - testC

[jira] [Comment Edited] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850215#comment-17850215 ] Kirk True edited comment on KAFKA-16792 at 6/3/24 9:09 PM: --- Th

[jira] [Comment Edited] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850215#comment-17850215 ] Kirk True edited comment on KAFKA-16792 at 6/3/24 9:03 PM: --- Th

[jira] [Comment Edited] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850215#comment-17850215 ] Kirk True edited comment on KAFKA-16792 at 5/30/24 9:41 PM:

[jira] [Comment Edited] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850215#comment-17850215 ] Kirk True edited comment on KAFKA-16792 at 5/30/24 9:40 PM:

[jira] [Comment Edited] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850215#comment-17850215 ] Kirk True edited comment on KAFKA-16792 at 5/30/24 9:34 PM:

[jira] [Comment Edited] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850215#comment-17850215 ] Kirk True edited comment on KAFKA-16792 at 5/29/24 10:04 PM: -

[jira] [Comment Edited] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850215#comment-17850215 ] Kirk True edited comment on KAFKA-16792 at 5/29/24 10:03 PM: -

[jira] [Assigned] (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 reassigned KAFKA-15305: - Assignee: (was: Kirk True) > The background thread should try to process the remaining task

[jira] [Updated] (KAFKA-16835) Add Support for consumer to read in commit order.

[ https://issues.apache.org/jira/browse/KAFKA-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16835: -- Component/s: clients > Add Support for consumer to read in commit order. > ---

[jira] [Assigned] (KAFKA-16777) New consumer should throw NoOffsetForPartitionException on continuous poll zero if no reset strategy

[ https://issues.apache.org/jira/browse/KAFKA-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16777: - Assignee: Kirk True > New consumer should throw NoOffsetForPartitionException on continuous pol

[jira] [Commented] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850215#comment-17850215 ] Kirk True commented on KAFKA-16792: --- These tests work with KAFKA-16200: - testResetUs

[jira] [Assigned] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16792: - Assignee: Kirk True > Enable consumer unit tests that fail to fetch offsets only for new consum

[jira] [Updated] (KAFKA-16200) Enforce that RequestManager implementations respect user-provided timeout

[ https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16200: -- Description: The intention of the {{CompletableApplicationEvent}} is for a {{Consumer}} to block wait

[jira] [Assigned] (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 reassigned KAFKA-15284: - Assignee: (was: Kirk True) > Implement ConsumerGroupProtocolVersionResolver to determine co

[jira] [Updated] (KAFKA-16639) AsyncKafkaConsumer#close does not send heartbeat to leave group

[ https://issues.apache.org/jira/browse/KAFKA-16639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16639: -- Priority: Critical (was: Major) > AsyncKafkaConsumer#close does not send heartbeat to leave group > -

[jira] [Updated] (KAFKA-16819) CoordinatorRequestManager seems to return 0ms during the coordinator discovery

[ https://issues.apache.org/jira/browse/KAFKA-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16819: -- Labels: consumer-threading-refactor (was: ) > CoordinatorRequestManager seems to return 0ms during th

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