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

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

2024-02-28 Thread Kirk True (Jira)
Kirk True created KAFKA-16312: - Summary: ConsumerRebalanceListener.onPartitionsAssigned should be called after joining, even if empty Key: KAFKA-16312 URL: https://issues.apache.org/jira/browse/KAFKA-16312

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

2024-02-27 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 > Investigate propagating subscription state updates via queues >

[jira] [Commented] (KAFKA-15878) KIP-768: Extend support for opaque (i.e. non-JWT) tokens in SASL/OAUTHBEARER

2024-02-27 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821352#comment-17821352 ] Kirk True commented on KAFKA-15878: --- [~philomathanuj]—are you able to assign this Jira to yourself? I

[jira] [Assigned] (KAFKA-15878) KIP-768: Extend support for opaque (i.e. non-JWT) tokens in SASL/OAUTHBEARER

2024-02-27 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15878: - Assignee: Kirk True > KIP-768: Extend support for opaque (i.e. non-JWT) tokens in

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

2024-02-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820747#comment-17820747 ] Kirk True commented on KAFKA-16160: --- [~pnee]—do you have some insights on how [~phuctran] can

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

2024-02-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820746#comment-17820746 ] Kirk True commented on KAFKA-16190: --- [~lucasbru]—could you take a look at the pull request for this

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

2024-02-22 Thread Kirk True (Jira)
[ 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.8.0 > Review fenced member unsubscribe/subscribe callbacks interaction >

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

2024-02-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16298: -- Fix Version/s: 3.8.0 > Ensure user callbacks exceptions are propagated to the user on consumer poll >

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

2024-02-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16298: -- Labels: callback kip-848-client-support (was: kip-848-client-support) > Ensure user callbacks

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

2024-02-21 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] [Updated] (KAFKA-16290) Investigate propagating subscription state updates via queues

2024-02-21 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.8.0 > Investigate propagating subscription state updates via queues >

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

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16008: - Assignee: Lucas Brutschy (was: Philip Nee) > Fix PlaintextConsumerTest.testMaxPollIntervalMs

[jira] [Assigned] (KAFKA-16152) Fix PlaintextConsumerTest.testStaticConsumerDetectsNewPartitionCreatedAfterRestart

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

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

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

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

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

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

2024-02-20 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: Bruno Cadonna (was: Kirk True) > Enforce that RequestManager implementations

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

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16008: - Assignee: Philip Nee (was: Kirk True) > Fix PlaintextConsumerTest.testMaxPollIntervalMs >

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

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reopened KAFKA-16200: --- > Enforce that RequestManager implementations respect user-provided timeout >

[jira] [Resolved] (KAFKA-15475) Request might retry forever even if the user API timeout expires

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-15475. --- Resolution: Fixed > Request might retry forever even if the user API timeout expires >

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

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16233: - Assignee: Philip Nee > Review auto-commit continuously committing when no progress >

[jira] [Updated] (KAFKA-16261) MembershipManagerImpl.updateSubscription fails if already empty subscription

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16261: -- Fix Version/s: 3.8.0 > MembershipManagerImpl.updateSubscription fails if already empty subscription >

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

2024-02-20 Thread Kirk True (Jira)
[ 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.8.0 > Review auto-commit continuously committing when no progress >

[jira] [Updated] (KAFKA-15694) New integration tests to have full coverage for preview

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15694: -- Fix Version/s: 3.8.0 > New integration tests to have full coverage for preview >

[jira] [Updated] (KAFKA-15840) Correct initialization of ConsumerGroupHeartbeat by client

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15840: -- Fix Version/s: 3.7.0 > Correct initialization of ConsumerGroupHeartbeat by client >

[jira] [Updated] (KAFKA-15651) Investigate auto commit guarantees during Consumer.assign()

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15651: -- Fix Version/s: 3.7.0 > Investigate auto commit guarantees during Consumer.assign() >

[jira] [Updated] (KAFKA-15631) Do not send new heartbeat request while another one in-flight

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15631: -- Fix Version/s: 3.7.0 > Do not send new heartbeat request while another one in-flight >

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