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

2024-01-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16142: - Assignee: Philip Nee > Update metrics documentation for errors and new metrics >

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

2024-01-15 Thread Kirk True (Jira)
Kirk True created KAFKA-16142: - Summary: Update metrics documentation for errors and new metrics Key: KAFKA-16142 URL: https://issues.apache.org/jira/browse/KAFKA-16142 Project: Kafka Issue

[jira] [Updated] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky

2024-01-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16134: -- Component/s: clients consumer >

[jira] [Updated] (KAFKA-16135) kafka.api.PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky

2024-01-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16135: -- Fix Version/s: 3.8.0 >

[jira] [Updated] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky

2024-01-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16134: -- Labels: consumer-threading-refactor kip-848-client-support (was: ) >

[jira] [Updated] (KAFKA-16135) kafka.api.PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky

2024-01-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16135: -- Labels: consumer-threading-refactor kip-848-client-support (was: ) >

[jira] [Updated] (KAFKA-16135) kafka.api.PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky

2024-01-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16135: -- Component/s: clients consumer >

[jira] [Updated] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky

2024-01-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16134: -- Fix Version/s: 3.8.0 >

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

2024-01-15 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: -- Fix Version/s: 3.8.0 > Commits during reconciliation always time out >

[jira] [Updated] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs

2024-01-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16029: -- Fix Version/s: 3.7.0 (was: 3.8.0) > Investigate cause of "Unable to find

[jira] [Updated] (KAFKA-15935) Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest

2024-01-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15935: -- Labels: flaky-test (was: flaky) > Flaky test: testRestartReplication() – >

[jira] [Updated] (KAFKA-15935) Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest

2024-01-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15935: -- Labels: flaky (was: ) > Flaky test: testRestartReplication() – >

[jira] [Updated] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs

2024-01-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16029: -- Description: >From [~mjsax]: {quote}Looking into AK unit/integration test logs for KS, I regularly

[jira] [Comment Edited] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs

2024-01-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806236#comment-17806236 ] Kirk True edited comment on KAFKA-16029 at 1/13/24 12:41 AM: - Based on input

[jira] [Commented] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs

2024-01-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806236#comment-17806236 ] Kirk True commented on KAFKA-16029: --- Based on input from [~ChrisEgerton], I was also able to reproduce

[jira] [Updated] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs

2024-01-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16029: -- Issue Type: Bug (was: Task) > Investigate cause of "Unable to find FetchSessionHandler for node X"

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

2024-01-11 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: -- Fix Version/s: 3.8.0 > AsyncKafkaConsumer: Add missing rebalance metrics >

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

2024-01-11 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: -- Component/s: clients > AsyncKafkaConsumer: Add missing heartbeat metrics >

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

2024-01-11 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: -- Component/s: clients > AsyncKafkaConsumer: Add missing rebalance metrics >

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

2024-01-11 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: -- Labels: consumer-threading-refactor (was: ) > AsyncKafkaConsumer: Add missing heartbeat metrics >

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

2024-01-11 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: -- Fix Version/s: 3.8.0 > AsyncKafkaConsumer: Add missing heartbeat metrics >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16022: -- Summary: AsyncKafkaConsumer sometimes complains “No current assignment for partition {}” (was:

[jira] [Updated] (KAFKA-15475) Timeout request might retry forever even if the user API times out in PrototypeAsyncConsumer

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15475: -- Priority: Critical (was: Minor) > Timeout request might retry forever even if the user API times out

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15320: -- Priority: Minor (was: Major) > Document event queueing patterns > >

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

2024-01-11 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: Minor (was: Major) > Client support for OffsetFetch and OffsetCommit with topic ID >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15173: -- Priority: Minor (was: Major) > Consumer event queues should be bounded >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16104: - Assignee: Kirk True > Enable additional PlaintextConsumerTest tests for new consumer >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16107: - Assignee: Lianet Magrans > Ensure consumer does not start fetching from added partitions until

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

2024-01-11 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: Kirk True > Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16009: - Assignee: Kirk True > Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation >

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

2024-01-11 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: Kirk True > Fix PlaintextConsumerTest.testMaxPollIntervalMs >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16023: - Assignee: Kirk True > PlaintextConsumerTest needs to wait for reconciliation to complete

[jira] [Assigned] (KAFKA-16100) Consistent handling of timeouts and responses for new consumer ApplicationEvents

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16100: - Assignee: Kirk True > Consistent handling of timeouts and responses for new consumer >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16019: - Assignee: Kirk True > Some of the tests in PlaintextConsumer can't seem to deterministically

[jira] [Assigned] (KAFKA-16004) Review new consumer inflight offset commit logic

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16004: - Assignee: Lianet Magrans > Review new consumer inflight offset commit logic >

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

2024-01-11 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: Kirk True > Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15993: - Assignee: Kirk True > Enable max poll integration tests that depend on callback invocation >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15999: - Assignee: Kirk True > Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15843: - Assignee: Lianet Magrans > Review consumer onPartitionsAssigned called with empty partitions >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15847: - Assignee: Lianet Magrans > Consider partial metadata requests for client reconciliation >

[jira] [Assigned] (KAFKA-15652) Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp()

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15652: - Assignee: Philip Nee > Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp() >

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

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

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

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

[jira] [Assigned] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15551: - Assignee: Lianet Magrans (was: Philip Nee) > Evaluate conditions for short circuiting

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

2024-01-11 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: Kirk True (was: Philip Nee) > Investigate ConsumerNetworkThreadTest's >

[jira] [Assigned] (KAFKA-15475) Timeout request might retry forever even if the user API times out in PrototypeAsyncConsumer

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15475: - Assignee: Kirk True (was: Philip Nee) > Timeout request might retry forever even if the user

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16110: - Assignee: Philip Nee (was: Kirk True) > Implement consumer performance tests >

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

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15283: - Assignee: Lianet Magrans > Client support for OffsetFetch and OffsetCommit with topic ID >

[jira] [Assigned] (KAFKA-15305) The background thread should try to process the remaining task until the shutdown timer is expired

2024-01-11 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15305: - Assignee: Kirk True (was: Philip Nee) > The background thread should try to process the

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

2024-01-11 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: -- Fix Version/s: 3.8.0 > AsyncKafkaConsumer: Add missing offset commit metrics >

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

2024-01-11 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: -- Labels: consumer-threading-refactor (was: ) > AsyncKafkaConsumer: Add missing offset commit metrics

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

2024-01-11 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: -- Component/s: clients metrics > AsyncKafkaConsumer: Add missing offset commit metrics

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

2024-01-11 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: -- Summary: Implement tests for tricky rebalance callback scenarios (was: Implement tests for tricky

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

2024-01-11 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: -- Summary: Some of the tests in PlaintextConsumer can't seem to deterministically invoke and verify the

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

2024-01-10 Thread Kirk True (Jira)
Kirk True created KAFKA-16112: - Summary: Review JMX metrics in Async Consumer and determine the missing ones Key: KAFKA-16112 URL: https://issues.apache.org/jira/browse/KAFKA-16112 Project: Kafka

[jira] [Created] (KAFKA-16111) Implement tests for tricky rebalance callbacks scenarios

2024-01-10 Thread Kirk True (Jira)
Kirk True created KAFKA-16111: - Summary: Implement tests for tricky rebalance callbacks scenarios Key: KAFKA-16111 URL: https://issues.apache.org/jira/browse/KAFKA-16111 Project: Kafka Issue

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

2024-01-10 Thread Kirk True (Jira)
Kirk True created KAFKA-16110: - Summary: Implement consumer performance tests Key: KAFKA-16110 URL: https://issues.apache.org/jira/browse/KAFKA-16110 Project: Kafka Issue Type: New Feature

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

2024-01-10 Thread Kirk True (Jira)
Kirk True created KAFKA-16109: - Summary: Ensure system tests cover the "simple consumer + commit" use case Key: KAFKA-16109 URL: https://issues.apache.org/jira/browse/KAFKA-16109 Project: Kafka

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

2024-01-10 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: -- Fix Version/s: 3.8.0 > Ensure consumer does not start fetching from added partitions until >

[jira] [Commented] (KAFKA-15475) Timeout request might retry forever even if the user API times out in PrototypeAsyncConsumer

2024-01-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804922#comment-17804922 ] Kirk True commented on KAFKA-15475: --- [~lianetm] would you kindly point me at the code in the two

[jira] [Commented] (KAFKA-15475) Timeout request might retry forever even if the user API times out in PrototypeAsyncConsumer

2024-01-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804921#comment-17804921 ] Kirk True commented on KAFKA-15475: --- [~lianetm] / [~pnee] —I need to refresh my memory about what it

[jira] [Updated] (KAFKA-16100) Consistent handling of timeouts and responses for new consumer ApplicationEvents

2024-01-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16100: -- Fix Version/s: 3.8.0 > Consistent handling of timeouts and responses for new consumer >

[jira] [Updated] (KAFKA-16100) Consistent handling of timeouts and responses for new consumer ApplicationEvents

2024-01-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16100: -- Labels: consumer-threading-refactor (was: ) > Consistent handling of timeouts and responses for new

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

2024-01-09 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: -- Fix Version/s: 3.8.0 > Enable additional PlaintextConsumerTest tests for new consumer >

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

2024-01-09 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: -- Labels: consumer-threading-refactor (was: ) > Enable additional PlaintextConsumerTest tests for new

[jira] [Updated] (KAFKA-15557) Investigate FetcherTest's/FetchRequestManager's duplicate metadata update in assignFromUserNoId

2024-01-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15557: -- Fix Version/s: 4.0.0 (was: 3.8.0) > Investigate

[jira] [Commented] (KAFKA-15250) DefaultBackgroundThread is running tight loop

2024-01-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804861#comment-17804861 ] Kirk True commented on KAFKA-15250: --- This is still an issue. If you enable detailed logging, it writes

[jira] [Reopened] (KAFKA-15250) DefaultBackgroundThread is running tight loop

2024-01-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reopened KAFKA-15250: --- Assignee: Kirk True (was: Philip Nee) > DefaultBackgroundThread is running tight loop >

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

2024-01-09 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: -- Fix Version/s: 3.8.0 > DefaultBackgroundThread is running tight loop >

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

2024-01-09 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: 4.0.0 (was: 3.8.0) > Implement

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

2024-01-08 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 tests to run twice: both for the old and the new

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

2024-01-08 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: -- Summary: Client support for new SubscriptionPattern based subscription (was: Client support for new

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

2024-01-08 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: -- Summary: Client support for java regex based subscription (was: Client support for java regex based

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

2024-01-08 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: -- Summary: Enable max poll integration tests that depend on callback invocation (was: Enable

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

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15847: -- Labels: consumer-threading-refactor (was: ) > Consider partial metadata requests for client

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

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

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

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15615: -- Fix Version/s: 3.8.0 (was: 4.0.0) > Improve handling of fetching during

[jira] [Updated] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15551: -- Fix Version/s: 3.8.0 (was: 4.0.0) > Evaluate conditions for short circuiting

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

2024-01-08 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 (was: consumer-threading-refactor flaky-test) >

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

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15320: -- Fix Version/s: 3.8.0 (was: 4.0.0) > Document event queueing patterns >

[jira] [Updated] (KAFKA-15321) Document consumer group member state machine

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15321: -- Fix Version/s: 3.8.0 (was: 4.0.0) > Document consumer group member state

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

2024-01-08 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: 4.0.0 (was: 3.8.0) > Add local assignor and ensure it cannot be

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

2024-01-08 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: 4.0.0 (was: 3.8.0) > Implement client support for KIP-848

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

2024-01-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15173: -- Fix Version/s: 3.8.0 (was: 4.0.0) > Consumer event queues should be bounded >

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

2024-01-08 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: 4.0.0 (was: 3.8.0) > Implement client support for KIP-848

[jira] [Updated] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

2023-12-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16034: -- Fix Version/s: 3.7.0 > AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on >

[jira] [Updated] (KAFKA-15692) New integration tests to ensure full coverage

2023-12-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15692: -- Parent: (was: KAFKA-14048) Issue Type: Test (was: Sub-task) > New integration tests to

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

2023-12-20 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: -- Parent: (was: KAFKA-14048) Issue Type: Improvement (was: Sub-task) > Integrate topicId

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

2023-12-20 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: Major (was: Minor) > Client support for java regex based subscription >

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

2023-12-20 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: -- Parent: (was: KAFKA-14048) Issue Type: New Feature (was: Sub-task) > Client support for

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

2023-12-20 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: -- Parent: (was: KAFKA-14048) Issue Type: New Feature (was: Sub-task) > Implement client

[jira] [Updated] (KAFKA-15835) Group commit/callbacks triggering logic

2023-12-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15835: -- Parent: (was: KAFKA-14048) Issue Type: Improvement (was: Sub-task) > Group

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

2023-12-20 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: -- Parent: (was: KAFKA-14048) Issue Type: New Feature (was: Sub-task) > Add local assignor

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

2023-12-20 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: -- Parent: (was: KAFKA-14048) Issue Type: Improvement (was: Sub-task) > Review retry logic

[jira] [Updated] (KAFKA-15542) Release member assignments on errors

2023-12-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15542: -- Parent: (was: KAFKA-14048) Issue Type: Improvement (was: Sub-task) > Release member

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

2023-12-20 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: -- Parent: (was: KAFKA-14048) Issue Type: New Feature (was: Sub-task) > Client support for

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

2023-12-20 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: -- Labels: consumer-threading-refactor kip-848 kip-848-client-support (was: kip-848

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

2023-12-20 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: Major (was: Minor) > Client support for new SubscriptionPattern based subscription >

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

2023-12-20 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: -- Parent: (was: KAFKA-14048) Issue Type: New Feature (was: Sub-task) > Implement client

[jira] [Updated] (KAFKA-15283) Add support for topic ID-related Consumer changes

2023-12-20 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: -- Parent: (was: KAFKA-14048) Issue Type: New Feature (was: Sub-task) > Add support for

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