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

2024-03-27 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: 4.0.0 (was: 3.8.0) > Client support for new SubscriptionPattern

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

2024-03-27 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

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

2024-03-27 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16109: -- Summary: Write system tests cover the "simple consumer + commit" use case (was: Ensure system tests

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

2024-03-27 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: -- Priority: Critical (was: Major) > Client support for OffsetFetch and OffsetCommit with topic ID >

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

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

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

2024-03-27 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15284: -- Fix Version/s: (was: 4.0.0) > Implement ConsumerGroupProtocolVersionResolver to determine

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

2024-03-27 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16110: -- Priority: Blocker (was: Major) > Implement consumer performance tests >

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

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

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

2024-03-27 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: -- Priority: Minor (was: Major) > New metrics for KIP-848 protocol > >

[jira] [Updated] (KAFKA-16433) beginningOffsets and offsetsForTimes don't behave consistently when providing a zero timeout

2024-03-27 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16433: -- Labels: consumer-threading-refactor timeout (was: consumer-threading-refactor) > beginningOffsets

[jira] [Updated] (KAFKA-16433) beginningOffsets and offsetsForTimes don't behave consistently when providing a zero timeout

2024-03-27 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16433: -- Issue Type: Bug (was: Task) > beginningOffsets and offsetsForTimes don't behave consistently when

[jira] [Updated] (KAFKA-16433) beginningOffsets and offsetsForTimes don't behave consistently when providing a zero timeout

2024-03-27 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16433: -- Component/s: clients > beginningOffsets and offsetsForTimes don't behave consistently when providing

[jira] [Updated] (KAFKA-16433) beginningOffsets and offsetsForTimes don't behave consistently when providing a zero timeout

2024-03-27 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16433: -- Fix Version/s: 3.8.0 > beginningOffsets and offsetsForTimes don't behave consistently when providing

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

2024-03-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831107#comment-17831107 ] Kirk True edited comment on KAFKA-16200 at 3/26/24 11:45 PM: - I've [made

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

2024-03-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831107#comment-17831107 ] Kirk True commented on KAFKA-16200: --- Making progress, need to do the following tasks: # Update the

[jira] [Assigned] (KAFKA-16427) KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER

2024-03-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16427: - Assignee: Kirk True > KafkaConsumer#position() does not respect timeout when group protocol is

[jira] [Updated] (KAFKA-16427) KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER

2024-03-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16427: -- Component/s: clients consumer > KafkaConsumer#position() does not respect timeout

[jira] [Updated] (KAFKA-16427) KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER

2024-03-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16427: -- Fix Version/s: 3.8.0 > KafkaConsumer#position() does not respect timeout when group protocol is >

[jira] [Updated] (KAFKA-16427) KafkaConsumer#position() does not respect timeout when group protocol is CONSUMER

2024-03-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16427: -- Labels: consumer-threading-refactor timeout (was: ) > KafkaConsumer#position() does not respect

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

2024-03-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831034#comment-17831034 ] Kirk True commented on KAFKA-15538: --- [~phuctran]—The {{ConsumerCoordinator}} has code to [update the

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

2024-03-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831031#comment-17831031 ] Kirk True commented on KAFKA-15558: --- [~schofielaj]—can you follow up on [~phuctran]’s question?

[jira] [Commented] (KAFKA-16022) AsyncKafkaConsumer sometimes complains “No current assignment for partition {}”

2024-03-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831030#comment-17831030 ] Kirk True commented on KAFKA-16022: --- [~pnee]—can you follow up on [~phuctran]'s question. Thanks! >

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

2024-03-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16200: - Assignee: Kirk True (was: Bruno Cadonna) > Enforce that RequestManager implementations

[jira] [Updated] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop

2024-03-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16160: -- Priority: Blocker (was: Major) > AsyncKafkaConsumer is trying to connect to a disconnected node in a

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

2024-03-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15250: -- Priority: Critical (was: Blocker) > ConsumerNetworkThread is running tight loop >

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

2024-03-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15250: -- Priority: Blocker (was: Major) > ConsumerNetworkThread is running tight loop >

[jira] [Assigned] (KAFKA-16271) Update consumer_rolling_upgrade_test.py to support KIP-848’s group protocol config

2024-03-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16271: - Assignee: Philip Nee > Update consumer_rolling_upgrade_test.py to support KIP-848’s group

[jira] [Resolved] (KAFKA-14246) Update threading model for Consumer

2024-03-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-14246. --- Resolution: Fixed > Update threading model for Consumer > --- > >

[jira] [Assigned] (KAFKA-14246) Update threading model for Consumer

2024-03-21 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-14246: - Assignee: Kirk True (was: Philip Nee) > Update threading model for Consumer >

[jira] [Assigned] (KAFKA-16275) Update kraft_upgrade_test.py to support KIP-848’s group protocol config

2024-03-21 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16275: - Assignee: (was: Kirk True) > Update kraft_upgrade_test.py to support KIP-848’s group

[jira] [Assigned] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-21 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16389: - Assignee: (was: Kirk True) > consumer_test.py’s test_valid_assignment fails with new

[jira] [Commented] (KAFKA-16275) Update kraft_upgrade_test.py to support KIP-848’s group protocol config

2024-03-21 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829660#comment-17829660 ] Kirk True commented on KAFKA-16275: --- [~dajac] [[~lucasbru]—Does migrating this test to use the new

[jira] [Assigned] (KAFKA-16275) Update kraft_upgrade_test.py to support KIP-848’s group protocol config

2024-03-21 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16275: - Assignee: Kirk True > Update kraft_upgrade_test.py to support KIP-848’s group protocol config

[jira] [Assigned] (KAFKA-16274) Update replica_scale_test.py to support KIP-848’s group protocol config

2024-03-21 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16274: - Assignee: Kirk True > Update replica_scale_test.py to support KIP-848’s group protocol config

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

2024-03-20 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: -- Summary: consume_bench_test.py failed using AsyncKafkaConsumer (was: consumer_bench_test.py failed

[jira] [Assigned] (KAFKA-16276) Update transactions_test.py to support KIP-848’s group protocol config

2024-03-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16276: - Assignee: Kirk True > Update transactions_test.py to support KIP-848’s group protocol config >

[jira] [Assigned] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16389: - Assignee: Kirk True (was: Lianet Magrans) > consumer_test.py’s test_valid_assignment fails

[jira] [Assigned] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16389: - Assignee: Lianet Magrans > consumer_test.py’s test_valid_assignment fails with new consumer >

[jira] [Comment Edited] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828538#comment-17828538 ] Kirk True edited comment on KAFKA-16389 at 3/19/24 11:21 PM: - I've attached

[jira] [Commented] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828538#comment-17828538 ] Kirk True commented on KAFKA-16389: --- I've attached a patch which _appears_ to address the issue in the

[jira] [Updated] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16389: -- Description: The following error is reported when running the {{test_valid_assignment}} test from

[jira] [Updated] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16389: -- Description: The following error is reported when running the {{test_valid_assignment}} test from

[jira] [Updated] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16389: -- Attachment: KAFKA-16389.patch > consumer_test.py’s test_valid_assignment fails with new consumer >

[jira] [Updated] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16389: -- Description: The following error is reported when running the {{test_valid_assignment}} test from

[jira] [Created] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-19 Thread Kirk True (Jira)
Kirk True created KAFKA-16389: - Summary: consumer_test.py’s test_valid_assignment fails with new consumer Key: KAFKA-16389 URL: https://issues.apache.org/jira/browse/KAFKA-16389 Project: Kafka

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

2024-03-18 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828089#comment-17828089 ] Kirk True commented on KAFKA-16217: --- [~calvinliu]—I reassigned this to you as you've already started

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

2024-03-18 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16217: - Assignee: Calvin Liu (was: Kirk True) > Transactional producer stuck in IllegalStateException

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

2024-03-18 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828075#comment-17828075 ] Kirk True commented on KAFKA-15282: --- [~zxcoccer]—you're certainly welcome to look at this. I would

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

2024-03-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827594#comment-17827594 ] Kirk True commented on KAFKA-16190: --- Thank you [~phong260702] for your help on this! :) > Member

[jira] [Commented] (KAFKA-16375) Fix logic for discarding reconciliation if member rejoined

2024-03-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827587#comment-17827587 ] Kirk True commented on KAFKA-16375: --- [~lianetm]—do we want this in 3.8? > Fix logic for discarding

[jira] [Assigned] (KAFKA-16274) Update replica_scale_test.py to support KIP-848’s group protocol config

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16274: - Assignee: (was: Philip Nee) > Update replica_scale_test.py to support KIP-848’s group

[jira] [Assigned] (KAFKA-16275) Update kraft_upgrade_test.py to support KIP-848’s group protocol config

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16275: - Assignee: (was: Philip Nee) > Update kraft_upgrade_test.py to support KIP-848’s group

[jira] [Assigned] (KAFKA-16271) Update consumer_rolling_upgrade_test.py to support KIP-848’s group protocol config

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16271: - Assignee: (was: Philip Nee) > Update consumer_rolling_upgrade_test.py to support KIP-848’s

[jira] [Assigned] (KAFKA-16276) Update transactions_test.py to support KIP-848’s group protocol config

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16276: - Assignee: (was: Philip Nee) > Update transactions_test.py to support KIP-848’s group

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16272: - Assignee: (was: Philip Nee) > Update connect_distributed_test.py to support KIP-848’s

[jira] [Assigned] (KAFKA-16276) Update transactions_test.py to support KIP-848’s group protocol config

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16276: - Assignee: Philip Nee (was: Kirk True) > Update transactions_test.py to support KIP-848’s

[jira] [Assigned] (KAFKA-16273) Update consume_bench_test.py to support KIP-848’s group protocol config

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16273: - Assignee: Philip Nee (was: Kirk True) > Update consume_bench_test.py to support KIP-848’s

[jira] [Assigned] (KAFKA-16271) Update consumer_rolling_upgrade_test.py to support KIP-848’s group protocol config

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16271: - Assignee: Philip Nee (was: Kirk True) > Update consumer_rolling_upgrade_test.py to support

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16272: - Assignee: Philip Nee (was: Kirk True) > Update connect_distributed_test.py to support

[jira] [Assigned] (KAFKA-16275) Update kraft_upgrade_test.py to support KIP-848’s group protocol config

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16275: - Assignee: Philip Nee (was: Kirk True) > Update kraft_upgrade_test.py to support KIP-848’s

[jira] [Assigned] (KAFKA-16274) Update replica_scale_test.py to support KIP-848’s group protocol config

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16274: - Assignee: Philip Nee (was: Kirk True) > Update replica_scale_test.py to support KIP-848’s

[jira] [Updated] (KAFKA-15691) Update system tests to use AsyncKafkaConsumer

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15691: -- Summary: Update system tests to use AsyncKafkaConsumer (was: Update system tests to use new

[jira] [Updated] (KAFKA-15691) Add new system tests to use new consumer

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15691: -- Priority: Blocker (was: Major) > Add new system tests to use new consumer >

[jira] [Reopened] (KAFKA-15691) Add new system tests to use new consumer

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reopened KAFKA-15691: --- > Add new system tests to use new consumer > > >

[jira] [Updated] (KAFKA-15691) Update system tests to use new consumer

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15691: -- Summary: Update system tests to use new consumer (was: Add new system tests to use new consumer) >

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16269: -- Description: This task is to update the test method(s) in {{reassign_partitions_test.py}} to support

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16270: -- Description: This task is to update the test method(s) in {{snapshot_test.py}} to support the 

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16275: -- Description: This task is to update the test method(s) in {{kraft_upgrade_test.py}} to support the 

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16273: -- Description: This task is to update the test method(s) in {{consume_bench_test.py}} to support the 

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16267: -- Description: This task is to update the test method(s) in {{consumer_group_command_test.py}}  to

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16269: -- Description: This task is to update the test method(s) in {{reassign_partitions_test.py}} to support

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16268: -- Description: This task is to update the test method(s) in {{fetch_from_follower_test.py}} to support

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16272: -- Description: This task is to update the test method(s) in {{connect_distributed_test.py}} to support

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16274: -- Description: This task is to update the test method(s) in {{replica_scale_test.py}} to support the 

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16271: -- Description: This task is to update the test method(s) in {{consumer_rolling_upgrade_test.py}} to

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16231: -- Description: This task is to update {{consumer_test.py}} to support the {{group.protocol}}

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

2024-03-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16276: -- Description: This task is to update the test method(s) in {{transactions_test.py}} to support the 

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

2024-03-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15250: -- Summary: ConsumerNetworkThread is running tight loop (was: DefaultBackgroundThread is running tight

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

2024-03-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16255: -- Priority: Minor (was: Major) > AsyncKafkaConsumer should not use partition.assignment.strategy >

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

2024-03-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15553: -- Priority: Minor (was: Major) > Review consumer positions update > >

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

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

[jira] [Assigned] (KAFKA-16298) Ensure user callbacks exceptions are propagated to the user on consumer poll

2024-03-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16298: - Assignee: Kirk True > Ensure user callbacks exceptions are propagated to the user on consumer

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

2024-03-05 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: -- Labels: consumer-threading-refactor (was: ) > Performance regression on close consumer after

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

2024-03-05 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: -- Component/s: clients > Performance regression on close consumer after upgrading to 3.5.0 >

[jira] [Assigned] (KAFKA-16227) Console consumer fails with `IllegalStateException`

2024-03-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16227: - Assignee: Bruno Cadonna (was: Philip Nee) > Console consumer fails with

[jira] [Assigned] (KAFKA-16224) Fix handling of deleted topic when auto-committing before revocation

2024-03-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16224: - Assignee: Bruno Cadonna (was: Lianet Magrans) > Fix handling of deleted topic when

[jira] [Updated] (KAFKA-16312) ConsumerRebalanceListener.onPartitionsAssigned() should be called after joining, even if empty

2024-03-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16312: -- Priority: Critical (was: Major) > ConsumerRebalanceListener.onPartitionsAssigned() should be called

[jira] [Assigned] (KAFKA-16312) ConsumerRebalanceListener.onPartitionsAssigned() should be called after joining, even if empty

2024-03-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16312: - Assignee: Lucas Brutschy (was: Lianet Magrans) >

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

2024-02-29 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: Kirk True > Investigate propagating metadata updates via queues >

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

2024-02-29 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822246#comment-17822246 ] Kirk True commented on KAFKA-16290: --- I just filed KAFKA-16315 which has a similar feel to this design

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

2024-02-29 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: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support (was: kip-848) > Investigate

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

2024-02-29 Thread Kirk True (Jira)
Kirk True created KAFKA-16315: - Summary: Investigate propagating metadata updates via queues Key: KAFKA-16315 URL: https://issues.apache.org/jira/browse/KAFKA-16315 Project: Kafka Issue Type:

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

2024-02-29 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822245#comment-17822245 ] Kirk True commented on KAFKA-16290: --- [~cadonna]—do we feel we have investigated this sufficiently? Are

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

2024-02-29 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: Bruno Cadonna (was: Kirk True) > Investigate propagating subscription state updates

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

2024-02-28 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821910#comment-17821910 ] Kirk True commented on KAFKA-16290: --- There are many {{Consumer}} APIs in which the

[jira] [Updated] (KAFKA-16227) Console consumer fails with `IllegalStateException`

2024-02-28 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16227: -- Priority: Blocker (was: Critical) > Console consumer fails with `IllegalStateException` >

[jira] [Updated] (KAFKA-16312) ConsumerRebalanceListener.onPartitionsAssigned() should be called after joining, even if empty

2024-02-28 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16312: -- Summary: ConsumerRebalanceListener.onPartitionsAssigned() should be called after joining, even if

[jira] [Commented] (KAFKA-16185) Fix client reconciliation of same assignment received in different epochs

2024-02-28 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821811#comment-17821811 ] Kirk True commented on KAFKA-16185: --- Please take a look at KAFKA-16312 to see if it is related. > Fix

[jira] [Commented] (KAFKA-16312) ConsumerRebalanceListener.onPartitionsAssigned should be called after joining, even if empty

2024-02-28 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821810#comment-17821810 ] Kirk True commented on KAFKA-16312: --- Perhaps KAFKA-16185 will resolve this, but in case it turns out

[jira] [Updated] (KAFKA-16312) ConsumerRebalanceListener.onPartitionsAssigned should be called after joining, even if empty

2024-02-28 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16312: -- Description: There is a difference between the {{LegacyKafkaConsumer}} and {{AsyncKafkaConsumer}}

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