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

2024-07-29 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16390: -- Component/s: clients > consume_bench_test.py failed using AsyncKafkaConsumer > ---

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

2024-07-29 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869464#comment-17869464 ] Kirk True commented on KAFKA-16390: --- [~frankvicky] transferring the Jira to you and ma

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

2024-07-29 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16390: - Assignee: TengYao Chi (was: Kirk True) > consume_bench_test.py failed using AsyncKafkaConsumer

[jira] [Updated] (KAFKA-17209) Revisit testCurrentLag for AsyncKafkaConsumer

2024-07-29 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17209: -- Labels: kip-848-client-support (was: ) > Revisit testCurrentLag for AsyncKafkaConsumer >

[jira] [Updated] (KAFKA-17209) Revisit testCurrentLag for AsyncKafkaConsumer

2024-07-29 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17209: -- Component/s: clients unit tests > Revisit testCurrentLag for AsyncKafkaConsumer > ---

[jira] [Updated] (KAFKA-14830) Illegal state error in transactional producer

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14830: -- Priority: Critical (was: Major) > Illegal state error in transactional producer > ---

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

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15402: -- Priority: Critical (was: Major) > Performance regression on close consumer after upgrading to 3.5.0 >

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

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16444: -- Priority: Minor (was: Major) > Run KIP-848 unit tests under code coverage > -

[jira] [Updated] (KAFKA-17182) Consumer's fetch sessions are evicted too quickly

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17182: -- Priority: Critical (was: Major) > Consumer's fetch sessions are evicted too quickly > ---

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

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15320: - Assignee: (was: Kirk True) > Document event queueing patterns > ---

[jira] [Updated] (KAFKA-17183) New consumer system tests pass for subset of tests, but fail if running all tests

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17183: -- Priority: Blocker (was: Major) > New consumer system tests pass for subset of tests, but fail if runn

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

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15638: - Assignee: (was: Kirk True) > Investigate ConsumerNetworkThreadTest's testPollResultTimer >

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

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

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

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16109: - Assignee: (was: Kirk True) > Write system tests cover the "simple consumer + commit" use ca

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

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16315: - Assignee: (was: Kirk True) > Investigate propagating metadata updates via queues >

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

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15173: - Assignee: (was: Kirk True) > Consumer event queues should be bounded >

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

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16642: - Assignee: (was: Kirk True) > Update KafkaConsumerTest to show parameters in test lists > --

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

2024-07-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16966: - Assignee: (was: Kirk True) > Allow offset commit fetch to reuse previous request if partiti

[jira] [Created] (KAFKA-17208) replica_scale_test.py fails for new consumer

2024-07-26 Thread Kirk True (Jira)
Kirk True created KAFKA-17208: - Summary: replica_scale_test.py fails for new consumer Key: KAFKA-17208 URL: https://issues.apache.org/jira/browse/KAFKA-17208 Project: Kafka Issue Type: Bug

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

2024-07-24 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868508#comment-17868508 ] Kirk True commented on KAFKA-16390: --- It appears that the relevant configuration was re

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

2024-07-24 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868508#comment-17868508 ] Kirk True edited comment on KAFKA-16390 at 7/25/24 12:14 AM: -

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

2024-07-24 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868507#comment-17868507 ] Kirk True commented on KAFKA-16390: --- [~chia7712]—sorry for the late reply. What you'r

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

2024-07-24 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16985: -- Affects Version/s: 3.8.0 > Ensure consumer sends leave request on close even if interrupted >

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

2024-07-24 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868487#comment-17868487 ] Kirk True commented on KAFKA-16985: --- [~lianetm]—are we expecting the "clean leave" to

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

2024-07-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867890#comment-17867890 ] Kirk True commented on KAFKA-15999: --- [~brendendeluna] — can you update the status of t

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

2024-07-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867889#comment-17867889 ] Kirk True commented on KAFKA-16558: --- [~brendendeluna] — can you update the status of t

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

2024-07-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867887#comment-17867887 ] Kirk True commented on KAFKA-16899: --- [~linu] — can you move this to "Patch Available"

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

2024-07-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867886#comment-17867886 ] Kirk True commented on KAFKA-15588: --- The PR linked to this Jira doesn't seem like it's

[jira] [Commented] (KAFKA-17163) Revisit testSubscriptionOnInvalidTopic and testPollAuthenticationFailure for AsyncKafkaConsumer

2024-07-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867888#comment-17867888 ] Kirk True commented on KAFKA-17163: --- [~taijuwu] — can you move this Jira to Patch Avai

[jira] [Updated] (KAFKA-14438) Throw error when consumer configured with empty/whitespace-only group.id for AsyncKafkaConsumer

2024-07-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14438: -- Component/s: clients > Throw error when consumer configured with empty/whitespace-only group.id for >

[jira] [Updated] (KAFKA-16675) Move rebalance callback test for positions to callbacks test file

2024-07-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16675: -- Component/s: clients > Move rebalance callback test for positions to callbacks test file > ---

[jira] [Updated] (KAFKA-16406) Split long-running consumer integration test

2024-07-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16406: -- Component/s: clients consumer > Split long-running consumer integration test > --

[jira] [Updated] (KAFKA-16406) Split long-running consumer integration test

2024-07-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16406: -- Labels: consumer integration-tests kip-848-client-support (was: consumer kip-848-client-support) > S

[jira] [Created] (KAFKA-17182) Consumer's fetch sessions are evicted too quickly

2024-07-22 Thread Kirk True (Jira)
Kirk True created KAFKA-17182: - Summary: Consumer's fetch sessions are evicted too quickly Key: KAFKA-17182 URL: https://issues.apache.org/jira/browse/KAFKA-17182 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-17017) AsyncConsumer#unsubscribe does not clean the assigned partitions

2024-07-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17017: -- Component/s: clients consumer > AsyncConsumer#unsubscribe does not clean the assigned

[jira] [Created] (KAFKA-17183) New consumer system tests pass for subset of tests, but fail if running all tests

2024-07-22 Thread Kirk True (Jira)
Kirk True created KAFKA-17183: - Summary: New consumer system tests pass for subset of tests, but fail if running all tests Key: KAFKA-17183 URL: https://issues.apache.org/jira/browse/KAFKA-17183 Project:

[jira] [Updated] (KAFKA-17163) Revisit testSubscriptionOnInvalidTopic and testPollAuthenticationFailure for AsyncKafkaConsumer

2024-07-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17163: -- Component/s: clients > Revisit testSubscriptionOnInvalidTopic and testPollAuthenticationFailure for >

[jira] [Updated] (KAFKA-17154) New consumer subscribe may join group without a call to consumer.poll

2024-07-17 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17154: -- Component/s: clients > New consumer subscribe may join group without a call to consumer.poll > ---

[jira] [Updated] (KAFKA-17129) Revisit FindCoordinatorResponse in KafkaConsumerTest

2024-07-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17129: -- Component/s: clients consumer > Revisit FindCoordinatorResponse in KafkaConsumerTest

[jira] [Updated] (KAFKA-17116) New consumer may not send effective leave group if member ID received after close

2024-07-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17116: -- Component/s: clients > New consumer may not send effective leave group if member ID received after >

[jira] [Updated] (KAFKA-17115) Closing newly-created legacy consumers during rebalance can cause rebalances to hang

2024-07-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17115: -- Component/s: clients > Closing newly-created legacy consumers during rebalance can cause rebalances >

[jira] [Assigned] (KAFKA-17066) New consumer updateFetchPositions should perform all operations in background thread

2024-07-10 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-17066: - Assignee: Kirk True > New consumer updateFetchPositions should perform all operations in backgr

[jira] [Updated] (KAFKA-17088) REQUEST_TIMED_OUT occurs intermittently in the kafka Producer client

2024-07-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17088: -- Component/s: clients producer (was: core) > REQUEST_TIMED_OUT o

[jira] [Updated] (KAFKA-17093) KafkaConsumer.seekToEnd should return LSO

2024-07-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17093: -- Component/s: clients > KafkaConsumer.seekToEnd should return LSO > --

[jira] [Updated] (KAFKA-17092) Revisit `KafkaConsumerTest#testBeginningOffsetsTimeout` for AsyncConsumer

2024-07-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17092: -- Component/s: clients consumer unit tests > Revisit `KafkaConsumerTes

[jira] [Updated] (KAFKA-17066) New consumer updateFetchPositions should perform all operations in background thread

2024-07-03 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17066: -- Component/s: clients > New consumer updateFetchPositions should perform all operations in background

[jira] [Updated] (KAFKA-17064) New consumer assign should update assignment in background thread

2024-07-02 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17064: -- Component/s: clients consumer > New consumer assign should update assignment in backg

[jira] [Created] (KAFKA-17060) Rename LegacyKafkaConsumer to ClassicKafkaConsumer

2024-07-01 Thread Kirk True (Jira)
Kirk True created KAFKA-17060: - Summary: Rename LegacyKafkaConsumer to ClassicKafkaConsumer Key: KAFKA-17060 URL: https://issues.apache.org/jira/browse/KAFKA-17060 Project: Kafka Issue Type: Impr

[jira] [Created] (KAFKA-17040) Unknown telemetry state: TERMINATED thrown when closing AsyncKafkaConsumer

2024-06-25 Thread Kirk True (Jira)
Kirk True created KAFKA-17040: - Summary: Unknown telemetry state: TERMINATED thrown when closing AsyncKafkaConsumer Key: KAFKA-17040 URL: https://issues.apache.org/jira/browse/KAFKA-17040 Project: Kafka

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

2024-06-24 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16142: -- Summary: Update metrics documentation for errors (was: Update metrics documentation for errors and ne

[jira] [Assigned] (KAFKA-16143) New JMX metrics for AsyncKafkaConsumer

2024-06-24 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16143: - Assignee: Brenden DeLuna (was: Philip Nee) > New JMX metrics for AsyncKafkaConsumer >

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

2024-06-24 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16142: -- Description: We need to identify the “errors” that exist in the current JMX documentation and resolve

[jira] [Updated] (KAFKA-16143) New JMX metrics for AsyncKafkaConsumer

2024-06-24 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16143: -- Summary: New JMX metrics for AsyncKafkaConsumer (was: New metrics for KIP-848 protocol) > New JMX me

[jira] [Updated] (KAFKA-17019) Producer TimeoutException should include root cause

2024-06-21 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17019: -- Component/s: clients > Producer TimeoutException should include root cause > -

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

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

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

2024-06-21 Thread Kirk True (Jira)
[ 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

2024-06-21 Thread Kirk True (Jira)
[ 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

2024-06-21 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

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

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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

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

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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15283: -- Fix Version/s: 4.0.0 > Client support for OffsetFetch and OffsetCommit with topic ID > ---

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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-17 Thread Kirk True (Jira)
[ 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

2024-06-15 Thread Kirk True (Jira)
[ 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

2024-06-15 Thread Kirk True (Jira)
[ 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)

2024-06-15 Thread Kirk True (Jira)
[ 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)

2024-06-15 Thread Kirk True (Jira)
[ 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

2024-06-14 Thread Kirk True (Jira)
[ 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

2024-06-14 Thread Kirk True (Jira)
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

2024-06-13 Thread Kirk True (Jira)
[ 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

2024-06-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16000: -- 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?

2024-06-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15867: -- 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 {}”

2024-06-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16022: -- Fix Version/s: 3.9.0 (was: 3.8.0) > AsyncKafkaConsumer sometimes complains “No

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