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

2024-02-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16272: - Summary: Update connect_distributed_test.py to support KIP-848’s group protocol config Key: KAFKA-16272 URL: https://issues.apache.org/jira/browse/KAFKA-16272 Project: Kafk

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

2024-02-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16271: - Summary: Update consumer_rolling_upgrade_test.py to support KIP-848’s group protocol config Key: KAFKA-16271 URL: https://issues.apache.org/jira/browse/KAFKA-16271 Project:

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

2024-02-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16273: - Summary: Update consume_bench_test.py to support KIP-848’s group protocol config Key: KAFKA-16273 URL: https://issues.apache.org/jira/browse/KAFKA-16273 Project: Kafka

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

2024-02-17 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818209#comment-17818209 ] Kirk True commented on KAFKA-16231: --- Progress has been made on this. The static member

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

2024-02-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16270: - Summary: Update snapshot_test.py to support KIP-848’s group protocol config Key: KAFKA-16270 URL: https://issues.apache.org/jira/browse/KAFKA-16270 Project: Kafka

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

2024-02-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16269: - Summary: Update reassign_partitions_test.py to support KIP-848’s group protocol config Key: KAFKA-16269 URL: https://issues.apache.org/jira/browse/KAFKA-16269 Project: Kafk

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

2024-02-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16268: - Summary: Update fetch_from_follower_test.py to support KIP-848’s group protocol config Key: KAFKA-16268 URL: https://issues.apache.org/jira/browse/KAFKA-16268 Project: Kafk

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

2024-02-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16267: - Summary: Update consumer_group_command_test.py to support KIP-848’s group protocol config Key: KAFKA-16267 URL: https://issues.apache.org/jira/browse/KAFKA-16267 Project: K

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

2024-02-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16256: - Assignee: Kirk True > Update ConsumerConfig to validate use of group.remote.assignor and > par

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

2024-02-14 Thread Kirk True (Jira)
Kirk True created KAFKA-16256: - Summary: Update ConsumerConfig to validate use of group.remote.assignor and partition.assignment.strategy based on group.protocol Key: KAFKA-16256 URL: https://issues.apache.org/jira/br

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

2024-02-14 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: -- Description: The {{partition.assignment.strategy}} configuration is used to specify a list of zero or

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

2024-02-14 Thread Kirk True (Jira)
Kirk True created KAFKA-16255: - Summary: AsyncKafkaConsumer should not use partition.assignment.strategy Key: KAFKA-16255 URL: https://issues.apache.org/jira/browse/KAFKA-16255 Project: Kafka Is

[jira] [Updated] (KAFKA-16243) Idle kafka-console-consumer with new consumer group protocol preemptively leaves group

2024-02-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16243: -- Priority: Critical (was: Major) > Idle kafka-console-consumer with new consumer group protocol preemp

[jira] [Updated] (KAFKA-16235) auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION

2024-02-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16235: -- Component/s: clients > auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION > -

[jira] [Assigned] (KAFKA-16001) Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder

2024-02-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16001: - Assignee: (was: Kirk True) > Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilde

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

2024-02-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15638: -- Labels: consumer-threading-refactor timeout unit-tests (was: consumer-threading-refactor unit-tests)

[jira] [Assigned] (KAFKA-15615) Improve handling of fetching during metadata updates

2024-02-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15615: - Assignee: (was: Kirk True) > Improve handling of fetching during metadata updates > ---

[jira] [Assigned] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored

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

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

2024-02-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16156: - Assignee: Philip Nee > System test failing for new consumer on endOffsets with negative timesta

[jira] [Assigned] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator

2024-02-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16178: - Assignee: Lianet Magrans (was: Philip Nee) > AsyncKafkaConsumer doesn't retry joining the grou

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

2024-02-07 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: -- Labels: consumer-threading-refactor (was: ) > Review auto-commit continuously committing when no prog

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

2024-02-06 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}} configurat

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

2024-02-06 Thread Kirk True (Jira)
Kirk True created KAFKA-16231: - Summary: Update consumer_test.py to support KIP-848’s group protocol config Key: KAFKA-16231 URL: https://issues.apache.org/jira/browse/KAFKA-16231 Project: Kafka

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

2024-02-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16230: -- Summary: Update verifiable_consumer.py to support KIP-848’s group protocol config (was: Update verifi

[jira] [Updated] (KAFKA-16230) Update verifiable_consumer to support KIP-848’s group protocol config

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

[jira] [Created] (KAFKA-16230) Update verifiable_consumer to support KIP-848’s group protocol config

2024-02-06 Thread Kirk True (Jira)
Kirk True created KAFKA-16230: - Summary: Update verifiable_consumer to support KIP-848’s group protocol config Key: KAFKA-16230 URL: https://issues.apache.org/jira/browse/KAFKA-16230 Project: Kafka

[jira] [Updated] (KAFKA-16037) Update VerifiableConsumer to support KIP-848’s group protocol config

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

[jira] [Updated] (KAFKA-16037) Update VerifiableConsumer to support KIP-848’s group protocol config

2024-02-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16037: -- Description: This task is to allow the the system tests so that they execute the Consumer for both o

[jira] [Updated] (KAFKA-16037) Update VerifiableConsumer to support KIP-848’s group protocol config

2024-02-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16037: -- Summary: Update VerifiableConsumer to support KIP-848’s group protocol config (was: Upgrade existing

[jira] [Updated] (KAFKA-16037) Upgrade existing system tests to use new consumer

2024-02-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16037: -- Description: This task is to parameterize the system tests so that they execute the Consumer for both

[jira] [Assigned] (KAFKA-16037) Upgrade existing system tests to use new consumer

2024-02-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16037: - Assignee: Kirk True (was: Dongnuo Lyu) > Upgrade existing system tests to use new consumer > -

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

2024-02-06 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: Critical (was: Major) > Console consumer fails with `IllegalStateException` > -

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

2024-02-06 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: (was: Kirk True) > Console consumer fails with `IllegalStateException` >

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

2024-02-06 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: -- Labels: kip-848-client-support (was: consumer-threading-refactor) > Console consumer fails with `Ille

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

2024-02-06 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: -- Fix Version/s: 3.8.0 > Console consumer fails with `IllegalStateException` > -

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

2024-02-06 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: -- Component/s: consumer > Console consumer fails with `IllegalStateException` >

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

2024-02-06 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: -- Labels: consumer-threading-refactor (was: ) > Console consumer fails with `IllegalStateException` > -

[jira] [Assigned] (KAFKA-16155) Investigate testAutoCommitIntercept

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

[jira] [Updated] (KAFKA-16019) Some of the tests in PlaintextConsumer can't seem to deterministically invoke and verify the consumer callback

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16019: -- Priority: Critical (was: Major) > Some of the tests in PlaintextConsumer can't seem to deterministica

[jira] [Updated] (KAFKA-16155) Investigate testAutoCommitIntercept

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16155: -- Priority: Critical (was: Major) > Investigate testAutoCommitIntercept > -

[jira] [Updated] (KAFKA-16023) PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16023: -- Priority: Critical (was: Major) > PlaintextConsumerTest needs to wait for reconciliation to complete

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

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16008: -- Priority: Critical (was: Major) > Fix PlaintextConsumerTest.testMaxPollIntervalMs > -

[jira] [Updated] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16009: -- Priority: Critical (was: Major) > Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation >

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

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16010: -- Priority: Critical (was: Major) > Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPoll

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

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16152: -- Priority: Critical (was: Major) > Fix > PlaintextConsumerTest.testStaticConsumerDetectsNewPartitionC

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

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

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

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

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

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

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

2024-02-05 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: -- Fix Version/s: 4.0.0 (was: 3.8.0) > Ensure system tests cover the "simple consu

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

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814501#comment-17814501 ] Kirk True commented on KAFKA-16110: --- Yes, we can use Trogdor for some _basic_ performa

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

2024-02-05 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: -- Fix Version/s: 4.0.0 (was: 3.8.0) > Implement consumer performance tests >

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

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15999: -- Priority: Minor (was: Major) > Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder > --

[jira] [Updated] (KAFKA-16000) Migrate MembershipManagerImplTest away from ConsumerTestBuilder

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

[jira] [Updated] (KAFKA-16001) Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16001: -- Priority: Minor (was: Major) > Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder >

[jira] [Updated] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

2024-02-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15556: -- Priority: Minor (was: Major) > Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFail

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

2024-02-05 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: -- Priority: Minor (was: Major) > Update metrics documentation for errors and new metrics >

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

2024-02-05 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: What is the documentation to update here? AFAIUI, we're not changing or adding metrics fo

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

2024-02-05 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: -- Priority: Major (was: Critical) > Update metrics documentation for errors and new metrics > -

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

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

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

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

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

2024-02-02 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 (was: 3.8.0) > Client support for OffsetFetch and OffsetCo

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

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

[jira] [Updated] (KAFKA-15325) Integrate topicId in OffsetFetch and OffsetCommit async consumer calls

2024-02-02 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15325: -- Priority: Critical (was: Major) > Integrate topicId in OffsetFetch and OffsetCommit async consumer ca

[jira] [Updated] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose

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

[jira] [Updated] (KAFKA-15832) Trigger client reconciliation based on manager poll

2024-02-02 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15832: -- Priority: Critical (was: Major) > Trigger client reconciliation based on manager poll > -

[jira] [Updated] (KAFKA-15948) Refactor AsyncKafkaConsumer shutdown

2024-02-02 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15948: -- Priority: Critical (was: Major) > Refactor AsyncKafkaConsumer shutdown >

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

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

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

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

[jira] [Updated] (KAFKA-16033) Review client retry logic of OffsetFetch and OffsetCommit responses

2024-02-02 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16033: -- Priority: Critical (was: Major) > Review client retry logic of OffsetFetch and OffsetCommit responses

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

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

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

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

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

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

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

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

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

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

[jira] [Updated] (KAFKA-15942) Implement ConsumerInterceptor

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

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

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

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

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

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

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

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

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

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

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

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

2024-02-01 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: Kirk True > Transactional producer stuck in IllegalStateException during close >

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

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

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

2024-02-01 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15538: -- Priority: Critical (was: Major) > Client support for java regex based subscription >

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

2024-02-01 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: -- Priority: Major (was: Blocker) > Implement ConsumerGroupProtocolVersionResolver to determine consumer

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

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

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

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

[jira] [Updated] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky

2024-02-01 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16024: -- Labels: flaky-test integration-tests (was: flaky-test) > SaslPlaintextConsumerTest#testCoordinatorFai

[jira] [Updated] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky

2024-02-01 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16024: -- Component/s: (was: unit tests) > SaslPlaintextConsumerTest#testCoordinatorFailover is flaky >

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

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

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

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

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

2024-02-01 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: -- Issue Type: Improvement (was: Task) Priority: Critical (was: Major) > Update metrics documenta

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

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

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

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

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

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

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

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

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

2024-02-01 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: -- Fix Version/s: 4.0.0 (was: 3.8.0) > New metrics for KIP-848 protocol >

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

2024-02-01 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: -- Labels: kip-848-client-support metrics needs-kip (was: kip-848-client-support metrics) > New metrics

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

2024-02-01 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: -- Issue Type: Improvement (was: Task) > New metrics for KIP-848 protocol >

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

2024-02-01 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: -- Description: This task is to consider what _new_ metrics we need from the KIP-848 protocol that aren't

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

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

<    5   6   7   8   9   10   11   12   13   14   >