[jira] [Resolved] (KAFKA-16442) Update streams_standby_replica_test.py to support KIP-848’s group protocol config

2024-08-21 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16442. --- Resolution: Won't Fix This Jira was created prior to getting input from the Kafka Streams developers

[jira] [Updated] (KAFKA-17363) Flaky test: kafka.api.PlaintextConsumerCommitTest.testAutoCommitOnRebalance(String, String).quorum=kraft+kip848.groupProtocol=consumer

2024-08-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17363: -- Labels: integration-tests (was: ) > Flaky test: > kafka.api.PlaintextConsumerCommitTest.testAutoComm

[jira] [Updated] (KAFKA-17361) KAFKA producer thread hung or infinite wait state

2024-08-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17361: -- Component/s: clients producer > KAFKA producer thread hung or infinite wait state >

[jira] [Updated] (KAFKA-17363) Flaky test: kafka.api.PlaintextConsumerCommitTest.testAutoCommitOnRebalance(String, String).quorum=kraft+kip848.groupProtocol=consumer

2024-08-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17363: -- Component/s: clients consumer > Flaky test: > kafka.api.PlaintextConsumerCommitTest.

[jira] [Commented] (KAFKA-17338) ConsumerConfig should prevent using partition assignors with CONSUMER group protocol

2024-08-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875038#comment-17875038 ] Kirk True commented on KAFKA-17338: --- Take a look at the {{AbstractConfig.originals()}}

[jira] [Commented] (KAFKA-17338) ConsumerConfig should prevent using partition assignors with CONSUMER group protocol

2024-08-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874075#comment-17874075 ] Kirk True commented on KAFKA-17338: --- [~m1a2st]—sounds good! Thanks! > ConsumerConfig

[jira] [Commented] (KAFKA-16221) IllegalStateException from Producer

2024-08-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874074#comment-17874074 ] Kirk True commented on KAFKA-16221: --- I'm working in this area of invalid transaction s

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

2024-08-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reopened KAFKA-17208: --- > replica_scale_test.py fails for new consumer > > >

[jira] [Updated] (KAFKA-17337) ConsumerConfig should default to CONSUMER for group.protocol

2024-08-13 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17337: -- Description: {{ConsumerConfig}}’s default value for {{group.protocol}} should be changed from {{CLASSI

[jira] [Updated] (KAFKA-17337) ConsumerConfig should default to CONSUMER for group.protocol

2024-08-13 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17337: -- Summary: ConsumerConfig should default to CONSUMER for group.protocol (was: ConsumerConfig should def

[jira] [Updated] (KAFKA-17337) ConsumerConfig should set the group.protocol default to CONSUMER

2024-08-13 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17337: -- Summary: ConsumerConfig should set the group.protocol default to CONSUMER (was: Make CONSUMER group p

[jira] [Updated] (KAFKA-17337) ConsumerConfig should default to CONSUMER for the group.protocol

2024-08-13 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17337: -- Summary: ConsumerConfig should default to CONSUMER for the group.protocol (was: ConsumerConfig should

[jira] [Updated] (KAFKA-17338) ConsumerConfig should prevent using partition assignors with CONSUMER group protocol

2024-08-13 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17338: -- Summary: ConsumerConfig should prevent using partition assignors with CONSUMER group protocol (was: A

[jira] [Updated] (KAFKA-17338) Add validation to ConsumerConfig to prevent using partition assignors with CONSUMER group protocol

2024-08-13 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17338: -- Description: {{ConsumerConfig}} should be updated to include additional validation in {{postProcessPa

[jira] [Created] (KAFKA-17338) Add validation to ConsumerConfig to prevent using partition assignors with CONSUMER group protocol

2024-08-13 Thread Kirk True (Jira)
Kirk True created KAFKA-17338: - Summary: Add validation to ConsumerConfig to prevent using partition assignors with CONSUMER group protocol Key: KAFKA-17338 URL: https://issues.apache.org/jira/browse/KAFKA-17338

[jira] [Created] (KAFKA-17337) Make CONSUMER group protocol default

2024-08-13 Thread Kirk True (Jira)
Kirk True created KAFKA-17337: - Summary: Make CONSUMER group protocol default Key: KAFKA-17337 URL: https://issues.apache.org/jira/browse/KAFKA-17337 Project: Kafka Issue Type: Task Com

[jira] [Created] (KAFKA-17335) Lack of default for missing URL encoding option for OAuth causes NPE

2024-08-13 Thread Kirk True (Jira)
Kirk True created KAFKA-17335: - Summary: Lack of default for missing URL encoding option for OAuth causes NPE Key: KAFKA-17335 URL: https://issues.apache.org/jira/browse/KAFKA-17335 Project: Kafka

[jira] [Commented] (KAFKA-16818) Move event processing-related tests from ConsumerNetworkThreadTest to ApplicationEventProcessorTest

2024-08-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873053#comment-17873053 ] Kirk True commented on KAFKA-16818: --- Yes. Those tests are all basically testing that t

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

2024-08-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15588: - Assignee: (was: Lianet Magrans) > Purge the unsent offset commits/fetches when the member i

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

2024-08-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-15284. --- Resolution: Won't Fix This is not needed given the current approach the broker is using. > Implemen

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

2024-08-12 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: -- Labels: consumer-threading-refactor kip-848-client-support (was: consumer-threading-refactor) > Asyn

[jira] [Commented] (KAFKA-15909) Throw error when consumer configured with empty/whitespace-only group.id for LegacyKafkaConsumer

2024-08-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872946#comment-17872946 ] Kirk True commented on KAFKA-15909: --- [~yangpoan]—feel free to assign it to yourself an

[jira] [Commented] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

2024-08-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872944#comment-17872944 ] Kirk True commented on KAFKA-16792: --- [~yangpoan]—feel free to assign it to yourself. T

[jira] [Updated] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14567: -- Labels: eos transactions (was: eos) > Kafka Streams crashes after ProducerFencedException > -

[jira] [Updated] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14567: -- Component/s: producer > Kafka Streams crashes after ProducerFencedException > ---

[jira] [Updated] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14567: -- Fix Version/s: 4.0.0 (was: 3.9.0) > Kafka Streams crashes after ProducerFencedE

[jira] [Assigned] (KAFKA-16149) Aggressively expire unused client connections

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16149: - Assignee: (was: Kirk True) > Aggressively expire unused client connections > --

[jira] [Assigned] (KAFKA-15617) Investigate FetcherTest's/FetchRequestManager's testFetchingPendingPartitions and testInflightFetchOnPendingPartitions overlap

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15617: - Assignee: (was: Kirk True) > Investigate FetcherTest's/FetchRequestManager's testFetchingPe

[jira] [Assigned] (KAFKA-15606) Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15606: - Assignee: (was: Kirk True) > Investigate FetcherTest's/FetchRequestManager's testCompletedF

[jira] [Assigned] (KAFKA-15322) Possible thread leaks in AbstractCoordinatorTest

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15322: - Assignee: (was: Kirk True) > Possible thread leaks in AbstractCoordinatorTest > ---

[jira] [Assigned] (KAFKA-12989) MockClient should respect the request matcher passed to prepareUnsupportedVersionResponse

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-12989: - Assignee: (was: Kirk True) > MockClient should respect the request matcher passed to > pre

[jira] [Assigned] (KAFKA-15907) Remove previously deprecated Consumer features from 4.0

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15907: - Assignee: (was: Kirk True) > Remove previously deprecated Consumer features from 4.0 >

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

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16444: -- Fix Version/s: 4.0.0 (was: 3.9.0) > Run KIP-848 unit tests under code coverage

[jira] [Assigned] (KAFKA-15636) Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15636: - Assignee: (was: Kirk True) > Investigate FetcherTest's/FetchRequestManager's testFetchRespo

[jira] [Assigned] (KAFKA-15323) Possible thread leaks in ListOffsetsHandlerTest

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15323: - Assignee: (was: Kirk True) > Possible thread leaks in ListOffsetsHandlerTest >

[jira] [Assigned] (KAFKA-15909) Throw error when consumer configured with empty/whitespace-only group.id for LegacyKafkaConsumer

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15909: - Assignee: (was: Kirk True) > Throw error when consumer configured with empty/whitespace-onl

[jira] [Assigned] (KAFKA-15634) Investigate FetcherTest's/FetchRequestManager's testQuotaMetrics

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15634: - Assignee: (was: Kirk True) > Investigate FetcherTest's/FetchRequestManager's testQuotaMetri

[jira] [Assigned] (KAFKA-14686) MockAdminClient.createTopics does not provide TopicMetadataAndConfig

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-14686: - Assignee: (was: Kirk True) > MockAdminClient.createTopics does not provide TopicMetadataAnd

[jira] [Assigned] (KAFKA-15635) Investigate FetcherTest's/FetchRequestManager's testFetcherLeadMetric

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15635: - Assignee: (was: Kirk True) > Investigate FetcherTest's/FetchRequestManager's testFetcherLea

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

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15557: - Assignee: (was: Kirk True) > Investigate FetcherTest's/FetchRequestManager's duplicate meta

[jira] [Assigned] (KAFKA-13703) OAUTHBEARER client will not use defined truststore

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-13703: - Assignee: (was: Kirk True) > OAUTHBEARER client will not use defined truststore > -

[jira] [Assigned] (KAFKA-15637) Investigate FetcherTest's/FetchRequestManager's testFetchCompletedBeforeHandlerAdded

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15637: - Assignee: (was: Kirk True) > Investigate FetcherTest's/FetchRequestManager's > testFetchCo

[jira] [Updated] (KAFKA-16818) Move event processing-related tests from ConsumerNetworkThreadTest to ApplicationEventProcessorTest

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16818: -- Fix Version/s: 4.0.0 (was: 3.9.0) > Move event processing-related tests from Co

[jira] [Assigned] (KAFKA-16818) Move event processing-related tests from ConsumerNetworkThreadTest to ApplicationEventProcessorTest

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16818: - Assignee: (was: Kirk True) > Move event processing-related tests from ConsumerNetworkThread

[jira] [Assigned] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16792: - Assignee: (was: Kirk True) > Enable consumer unit tests that fail to fetch offsets only for

[jira] [Updated] (KAFKA-16792) Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16792: -- Fix Version/s: 4.0.0 (was: 3.9.0) > Enable consumer unit tests that fail to fet

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

2024-08-09 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: -- Component/s: config > Update ConsumerConfig to validate use of group.remote.assignor and > partition.

[jira] [Updated] (KAFKA-15773) Group protocol configuration should be validated

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15773: -- Component/s: config > Group protocol configuration should be validated > -

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

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16256. --- Resolution: Duplicate > Update ConsumerConfig to validate use of group.remote.assignor and > partit

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

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-17208. --- Resolution: Cannot Reproduce This seems to have been fixed as it is no longer seen after three test

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

2024-08-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-17183. --- Resolution: Cannot Reproduce This seems to have been fixed as it is no longer seen after three test

[jira] [Commented] (KAFKA-17286) Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic

2024-08-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872071#comment-17872071 ] Kirk True commented on KAFKA-17286: --- [~brandboat]—thanks for reporting and taking on t

[jira] [Updated] (KAFKA-17286) Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic

2024-08-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17286: -- Fix Version/s: 4.0.0 > Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic > ---

[jira] [Updated] (KAFKA-17286) Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic

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

[jira] [Updated] (KAFKA-17286) Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic

2024-08-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17286: -- Labels: flaky-test integration-test integration-tests kip-848-client-support (was: integration-test i

[jira] [Updated] (KAFKA-17293) New consumer HeartbeatRequestManager should rediscover disconnected coordinator

2024-08-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17293: -- Component/s: clients > New consumer HeartbeatRequestManager should rediscover disconnected > coordina

[jira] [Updated] (KAFKA-17286) Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic

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

[jira] [Updated] (KAFKA-17286) Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic

2024-08-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17286: -- Priority: Critical (was: Minor) > Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic >

[jira] [Updated] (KAFKA-17294) Handle retriable errors when fetching offsets in new consumer

2024-08-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17294: -- Component/s: clients > Handle retriable errors when fetching offsets in new consumer > ---

[jira] [Updated] (KAFKA-16460) New consumer times out consuming records in multiple consumer_test.py system tests

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16460: -- Priority: Blocker (was: Critical) > New consumer times out consuming records in multiple consumer_tes

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

2024-08-07 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: -- Issue Type: Test (was: Improvement) > Write system tests cover the "simple consumer + commit" use cas

[jira] [Updated] (KAFKA-16576) New consumer fails with assert in consumer_test.py’s test_consumer_failure system test

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16576: -- Priority: Blocker (was: Critical) > New consumer fails with assert in consumer_test.py’s test_consume

[jira] [Updated] (KAFKA-17295) New consumer fails with assert in consumer_test.py’s test_fencing_static_consumer system test

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17295: -- Priority: Blocker (was: Critical) > New consumer fails with assert in consumer_test.py’s > test_fenc

[jira] [Updated] (KAFKA-17219) Adjust system test framework for new protocol consumer

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17219: -- Priority: Blocker (was: Critical) > Adjust system test framework for new protocol consumer >

[jira] [Updated] (KAFKA-17219) Adjust system test framework for new protocol consumer

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17219: -- Issue Type: Bug (was: Task) > Adjust system test framework for new protocol consumer > --

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

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

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

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-16441: - Assignee: (was: Kirk True) > Update streams_broker_down_resilience_test.py to support KIP-8

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

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

[jira] [Updated] (KAFKA-16460) New consumer times out consuming records in multiple consumer_test.py system tests

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16460: -- Priority: Critical (was: Blocker) > New consumer times out consuming records in multiple consumer_tes

[jira] [Updated] (KAFKA-17219) Adjust system test framework for new protocol consumer

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17219: -- Fix Version/s: 4.0.0 > Adjust system test framework for new protocol consumer > --

[jira] [Updated] (KAFKA-17295) New consumer fails with assert in consumer_test.py’s test_fencing_static_consumer system test

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17295: -- Fix Version/s: 4.0.0 (was: 3.9.0) > New consumer fails with assert in consumer_

[jira] [Updated] (KAFKA-17219) Adjust system test framework for new protocol consumer

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17219: -- Priority: Critical (was: Major) > Adjust system test framework for new protocol consumer > --

[jira] [Updated] (KAFKA-17219) Adjust system test framework for new protocol consumer

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

[jira] [Updated] (KAFKA-17295) New consumer fails with assert in consumer_test.py’s test_fencing_static_consumer system test

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17295: -- Priority: Critical (was: Major) > New consumer fails with assert in consumer_test.py’s > test_fencin

[jira] [Updated] (KAFKA-16460) New consumer times out consuming records in multiple consumer_test.py system tests

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16460: -- Summary: New consumer times out consuming records in multiple consumer_test.py system tests (was: New

[jira] [Updated] (KAFKA-17295) New consumer fails with assert in consumer_test.py’s test_fencing_static_consumer system test

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17295: -- Summary: New consumer fails with assert in consumer_test.py’s test_fencing_static_consumer system test

[jira] [Updated] (KAFKA-16460) New consumer times out consuming records in consumer_test.py system test

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16460: -- Fix Version/s: 4.0.0 > New consumer times out consuming records in consumer_test.py system test >

[jira] [Reopened] (KAFKA-16460) New consumer times out consuming records in consumer_test.py system test

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reopened KAFKA-16460: --- Assignee: (was: Kirk True) > New consumer times out consuming records in consumer_test.py syst

[jira] [Updated] (KAFKA-16576) New consumer fails with assert in consumer_test.py’s test_consumer_failure system test

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16576: -- Fix Version/s: 4.0.0 (was: 3.9.0) > New consumer fails with assert in consumer_

[jira] [Updated] (KAFKA-16576) New consumer fails with assert in consumer_test.py’s test_consumer_failure system test

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16576: -- Priority: Critical (was: Minor) > New consumer fails with assert in consumer_test.py’s test_consumer_

[jira] [Created] (KAFKA-17295) test_fencing_static_consumer system test fails with new consumer

2024-08-07 Thread Kirk True (Jira)
Kirk True created KAFKA-17295: - Summary: test_fencing_static_consumer system test fails with new consumer Key: KAFKA-17295 URL: https://issues.apache.org/jira/browse/KAFKA-17295 Project: Kafka I

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

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

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

2024-08-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17183: -- Fix Version/s: 4.0.0 (was: 3.9.0) > New consumer system tests pass for subset o

[jira] [Updated] (KAFKA-17263) Sometimes KafkaConsumer.close will block the thread

2024-08-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17263: -- Component/s: clients consumer > Sometimes KafkaConsumer.close will block the thread >

[jira] [Commented] (KAFKA-17244) java.base/java.lang.VirtualThread$VThreadContinuation.onPinned

2024-08-01 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870336#comment-17870336 ] Kirk True commented on KAFKA-17244: --- Thanks for filing this ticket [~jianbin]. Two qu

[jira] [Updated] (KAFKA-17244) java.base/java.lang.VirtualThread$VThreadContinuation.onPinned

2024-08-01 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17244: -- Component/s: clients producer > java.base/java.lang.VirtualThread$VThreadContinuatio

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

2024-08-01 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16985: -- Labels: kip-848-client-support (was: ) > Ensure consumer sends leave request on close even if interru

[jira] [Updated] (KAFKA-17230) Kafka consumer client doesn't report node request-latency metrics

2024-07-31 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17230: -- Component/s: consumer metrics > Kafka consumer client doesn't report node request-lat

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

2024-07-31 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869982#comment-17869982 ] Kirk True commented on KAFKA-17116: --- {color:#172b4d}For the sake of discussion, if we

[jira] [Updated] (KAFKA-17223) Retrying the call after encoutering UnsupportedVersionException will cause ConcurrentModificationException

2024-07-31 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17223: -- Component/s: admin clients > Retrying the call after encoutering UnsupportedVersionEx

[jira] [Assigned] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException

2024-07-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-14567: - Assignee: Kirk True > Kafka Streams crashes after ProducerFencedException > ---

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

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

[jira] [Updated] (KAFKA-14831) Illegal state errors should be fatal in transactional producer

2024-07-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14831: -- Labels: transactions (was: ) > Illegal state errors should be fatal in transactional producer > -

[jira] [Updated] (KAFKA-15767) Redesign TransactionManager to avoid use of ThreadLocal

2024-07-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15767: -- Labels: transactions (was: ) > Redesign TransactionManager to avoid use of ThreadLocal >

[jira] [Updated] (KAFKA-15767) Redesign TransactionManager to avoid use of ThreadLocal

2024-07-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15767: -- Fix Version/s: 4.0.0 (was: 3.9.0) > Redesign TransactionManager to avoid use of

[jira] [Updated] (KAFKA-17219) Adjust system test framework for new protocol consumer

2024-07-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17219: -- Labels: kip-848-client-support (was: ) > Adjust system test framework for new protocol consumer > ---

[jira] [Commented] (KAFKA-17219) Adjust system test framework for new protocol consumer

2024-07-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869699#comment-17869699 ] Kirk True commented on KAFKA-17219: --- Thanks for tracking this down, [~dongnuolyu]. Wh

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

2024-07-30 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869689#comment-17869689 ] Kirk True commented on KAFKA-16109: --- [~yangpoan]—it's all yours :) > Write system tes

[jira] [Updated] (KAFKA-17211) kafka producer get stuck by Uncaught error in kafka producer I/O thread

2024-07-29 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17211: -- Component/s: producer > kafka producer get stuck by Uncaught error in kafka producer I/O thread > ---

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

2024-07-29 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869467#comment-17869467 ] Kirk True commented on KAFKA-17116: --- My understanding is: # This is an edge case # T

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