[jira] [Commented] (KAFKA-17623) Flaky testSeekPositionAndPauseNewlyAssignedPartitionOnPartitionsAssignedCallback

2024-12-23 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907941#comment-17907941 ] Kirk True commented on KAFKA-17623: --- [~yangpoan]—checking in on this ticket. Is this s

[jira] [Resolved] (KAFKA-18176) Consumer system tests failure due to unsupported protocol configs

2024-12-23 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-18176. --- Resolution: Won't Fix > Consumer system tests failure due to unsupported protocol configs >

[jira] [Updated] (KAFKA-18176) Consumer system tests failure due to unsupported protocol configs

2024-12-10 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18176: -- Fix Version/s: 4.0.0 > Consumer system tests failure due to unsupported protocol configs > ---

[jira] [Updated] (KAFKA-18176) Consumer system tests failure due to unsupported protocol configs

2024-12-10 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18176: -- Labels: kip-848-client-support (was: ) > Consumer system tests failure due to unsupported protocol co

[jira] [Updated] (KAFKA-17915) Convert Kafka Client system tests to use KRaft

2024-12-10 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17915: -- Labels: consumer-threading-refactor (was: ) > Convert Kafka Client system tests to use KRaft > --

[jira] [Updated] (KAFKA-18158) Add subscribePattern integration tests for subsequent subscription

2024-12-10 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18158: -- Fix Version/s: 4.0.0 > Add subscribePattern integration tests for subsequent subscription > --

[jira] [Updated] (KAFKA-18158) Add subscribePattern integration tests for subsequent subscription

2024-12-10 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18158: -- Component/s: clients > Add subscribePattern integration tests for subsequent subscription > --

[jira] [Updated] (KAFKA-18158) Add subscribePattern integration tests for subsequent subscription

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

[jira] [Updated] (KAFKA-18117) Support topic IDs in consumer SubscriptionState

2024-12-10 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18117: -- Component/s: clients > Support topic IDs in consumer SubscriptionState > -

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

2024-12-09 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 > Implement GroupProtocolResolver to dynamically determine consumer group > p

[jira] [Updated] (KAFKA-18189) CoordinatorRequestManager log message can include incorrect coordinator disconnect time

2024-12-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18189: -- Description: The {{CoordinatorRequestManager.markCoordinatorUnknown()}} method logs a warning for the

[jira] [Updated] (KAFKA-18189) CoordinatorRequestManager log message can include incorrect coordinator disconnect time

2024-12-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18189: -- Description: The {{{}C\{{{}oordinatorRequestManager.markCoordinatorUnknown(){} method logs a warn

[jira] [Updated] (KAFKA-18189) CoordinatorRequestManager log message can include incorrect coordinator disconnect time

2024-12-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18189: -- Description: The {{C{{{}oordinatorRequestManager.markCoordinatorUnknown(){} method logs a warning

[jira] [Updated] (KAFKA-18189) CoordinatorRequestManager log message can include incorrect coordinator disconnect time

2024-12-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18189: -- Summary: CoordinatorRequestManager log message can include incorrect coordinator disconnect time (was

[jira] [Updated] (KAFKA-18189) CoordinatorRequestManager log of time disconnected from coordinator is incorrect

2024-12-09 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18189: -- Description: The {{CoordinatorRequestManager}} outputs some logging when the client is not able to co

[jira] [Created] (KAFKA-18189) CoordinatorRequestManager log of time disconnected from coordinator is incorrect

2024-12-09 Thread Kirk True (Jira)
Kirk True created KAFKA-18189: - Summary: CoordinatorRequestManager log of time disconnected from coordinator is incorrect Key: KAFKA-18189 URL: https://issues.apache.org/jira/browse/KAFKA-18189 Project: K

[jira] [Commented] (KAFKA-17960) PlaintextAdminIntegrationTest.testConsumerGroups fails with CONSUMER group protocol

2024-12-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903789#comment-17903789 ] Kirk True commented on KAFKA-17960: --- It doesn't appear that KAFKA-18116 fixed this. I

[jira] [Commented] (KAFKA-18040) PlaintextProducerSendTest.testSendToPartitionWithFollowerShutdownShouldNotTimeout fails with CONSUMER group protocol

2024-12-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903787#comment-17903787 ] Kirk True commented on KAFKA-18040: --- In this test there are two brokers: a leader and

[jira] [Updated] (KAFKA-18176) Consumer system tests failure due to unsupported protocol configs

2024-12-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18176: -- Component/s: clients consumer > Consumer system tests failure due to unsupported prot

[jira] [Updated] (KAFKA-18031) Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt

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

[jira] [Updated] (KAFKA-17623) Flaky testSeekPositionAndPauseNewlyAssignedPartitionOnPartitionsAssignedCallback

2024-12-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17623: -- Labels: consumer-threading-refactor flaky-test integration-test (was: consumer-threading-refactor fla

[jira] [Commented] (KAFKA-18034) CommitRequestManager should fail pending requests on fatal coordinator errors

2024-12-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903179#comment-17903179 ] Kirk True commented on KAFKA-18034: --- {quote}I think this PR should wait for https://i

[jira] [Updated] (KAFKA-18156) VerifiableConsumer should ignore "--session-timeout" when using CONSUMER protocol

2024-12-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18156: -- Component/s: clients consumer tools > VerifiableConsumer should igno

[jira] [Commented] (KAFKA-18034) CommitRequestManager should fail pending requests on fatal coordinator errors

2024-12-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903180#comment-17903180 ] Kirk True commented on KAFKA-18034: --- [~m1a2st]—apologies if my previous inquiry about

[jira] [Updated] (KAFKA-18139) AsyncKafkaConsumer's ConsumerNetworkThread loop requires further optimization

2024-12-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18139: -- Component/s: clients > AsyncKafkaConsumer's ConsumerNetworkThread loop requires further optimization >

[jira] [Updated] (KAFKA-18143) Kafka consumer keeps getting records on poll after eviction from group

2024-12-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18143: -- Component/s: clients > Kafka consumer keeps getting records on poll after eviction from group > --

[jira] [Commented] (KAFKA-18160) Interrupting or waking up onPartitionsAssigned in AsyncConsumer can cause the ConsumerRebalanceListenerCallbackCompletedEvent to be skipped, potentially leading to cor

2024-12-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903178#comment-17903178 ] Kirk True commented on KAFKA-18160: --- Great catch! Hopefully the try/catch can be added

[jira] [Updated] (KAFKA-18160) Interrupting or waking up onPartitionsAssigned in AsyncConsumer can cause the ConsumerRebalanceListenerCallbackCompletedEvent to be skipped, potentially leading to corru

2024-12-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18160: -- Component/s: clients > Interrupting or waking up onPartitionsAssigned in AsyncConsumer can cause the

[jira] [Commented] (KAFKA-18034) CommitRequestManager should fail pending requests on fatal coordinator errors

2024-12-03 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17902809#comment-17902809 ] Kirk True commented on KAFKA-18034: --- [~m1a2st]—how's the progress on this ticket? > C

[jira] [Assigned] (KAFKA-17962) Upgrade Connect distributed system tests to handle CONSUMER group protocol

2024-12-03 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-17962: - Assignee: (was: Kirk True) > Upgrade Connect distributed system tests to handle CONSUMER gr

[jira] [Commented] (KAFKA-18034) CommitRequestManager should fail pending requests on fatal coordinator errors

2024-11-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901325#comment-17901325 ] Kirk True commented on KAFKA-18034: --- Thanks [~m1a2st]! > CommitRequestManager should

[jira] [Updated] (KAFKA-17962) Upgrade Connect distributed system tests to handle CONSUMER group protocol

2024-11-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17962: -- Component/s: connect > Upgrade Connect distributed system tests to handle CONSUMER group protocol > --

[jira] [Updated] (KAFKA-17962) Upgrade Connect distributed system tests to handle CONSUMER group protocol

2024-11-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17962: -- Description: Many of the system tests fail in {{connect_distributed_test.py}} because the parameteriz

[jira] [Updated] (KAFKA-17962) Upgrade Connect distributed system tests to handle CONSUMER group protocol

2024-11-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17962: -- Summary: Upgrade Connect distributed system tests to handle CONSUMER group protocol (was: test_pause_

[jira] [Assigned] (KAFKA-18040) PlaintextProducerSendTest.testSendToPartitionWithFollowerShutdownShouldNotTimeout fails with CONSUMER group protocol

2024-11-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-18040: - Assignee: Kirk True > PlaintextProducerSendTest.testSendToPartitionWithFollowerShutdownShouldNo

[jira] [Updated] (KAFKA-18087) Revert unnecessary integration testing of both consumer group protocols

2024-11-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18087: -- Summary: Revert unnecessary integration testing of both consumer group protocols (was: Revert unneces

[jira] [Updated] (KAFKA-18087) Revert unnecessary integration testing of both consumer group protocols

2024-11-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18087: -- Description: Many of the integration tests were migrated to a parameterized version that tests both t

[jira] [Created] (KAFKA-18087) Revert unnecessary integration testing of Consumers using both group protocols

2024-11-25 Thread Kirk True (Jira)
Kirk True created KAFKA-18087: - Summary: Revert unnecessary integration testing of Consumers using both group protocols Key: KAFKA-18087 URL: https://issues.apache.org/jira/browse/KAFKA-18087 Project: Kaf

[jira] [Commented] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest

2024-11-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899567#comment-17899567 ] Kirk True commented on KAFKA-16176: --- Closing this as fixed as it is not currently flak

[jira] [Created] (KAFKA-18040) PlaintextProducerSendTest.testSendToPartitionWithFollowerShutdownShouldNotTimeout fails with CONSUMER group protocol

2024-11-19 Thread Kirk True (Jira)
Kirk True created KAFKA-18040: - Summary: PlaintextProducerSendTest.testSendToPartitionWithFollowerShutdownShouldNotTimeout fails with CONSUMER group protocol Key: KAFKA-18040 URL: https://issues.apache.org/jira/brows

[jira] [Resolved] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest

2024-11-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16176. --- Resolution: Fixed > Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – > kafka.a

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

2024-11-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16460. --- Reviewer: Lianet Magrans Resolution: Fixed > New consumer times out consuming records in multi

[jira] [Commented] (KAFKA-18031) Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt

2024-11-18 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899301#comment-17899301 ] Kirk True commented on KAFKA-18031: --- [~lianetm]—thanks for calling attention to this n

[jira] [Assigned] (KAFKA-18031) Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt

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

[jira] [Updated] (KAFKA-18017) New consumer should notify HB errors to group manager after errors have been handled/propagated

2024-11-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-18017: -- Component/s: clients > New consumer should notify HB errors to group manager after errors have been >

[jira] [Resolved] (KAFKA-17519) Define and validate correctness of Consumer.close() and its timeout when thread is interrupted

2024-11-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-17519. --- Assignee: Kirk True (was: PoAn Yang) Resolution: Fixed > Define and validate correctness of C

[jira] [Commented] (KAFKA-17519) Define and validate correctness of Consumer.close() and its timeout when thread is interrupted

2024-11-14 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898454#comment-17898454 ] Kirk True commented on KAFKA-17519: --- I think we've done most of the legwork. My only h

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

2024-11-13 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898117#comment-17898117 ] Kirk True commented on KAFKA-16460: --- cc [~lianetm] [~pnee] > New consumer times out c

[jira] [Reopened] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-13 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reopened KAFKA-17962: --- > test_pause_and_resume_sink fails with "Failed to consume messages after > resuming sink connector" wi

[jira] [Resolved] (KAFKA-17681) Fix unstable consumer_test.py#test_fencing_static_consumer

2024-11-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-17681. --- Resolution: Cannot Reproduce > Fix unstable consumer_test.py#test_fencing_static_consumer >

[jira] [Reopened] (KAFKA-16949) System test test_dynamic_logging in connect_distributed_test is failing

2024-11-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reopened KAFKA-16949: --- > System test test_dynamic_logging in connect_distributed_test is failing >

[jira] [Resolved] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-17962. --- Resolution: Cannot Reproduce > test_pause_and_resume_sink fails with "Failed to consume messages aft

[jira] [Commented] (KAFKA-16949) System test test_dynamic_logging in connect_distributed_test is failing

2024-11-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897782#comment-17897782 ] Kirk True commented on KAFKA-16949: --- [~sagarrao]—unfortunately I'm seeing this again i

[jira] [Created] (KAFKA-18002) Upgrade connect_distributed_test.py's test_exactly_once_source to support different group.protocol values

2024-11-12 Thread Kirk True (Jira)
Kirk True created KAFKA-18002: - Summary: Upgrade connect_distributed_test.py's test_exactly_once_source to support different group.protocol values Key: KAFKA-18002 URL: https://issues.apache.org/jira/browse/KAFKA-1800

[jira] [Assigned] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-12 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-17962: - Assignee: Kirk True > test_pause_and_resume_sink fails with "Failed to consume messages after

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

2024-11-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896842#comment-17896842 ] Kirk True commented on KAFKA-16460: --- My question is: why was consumer A's assignment r

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

2024-11-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896841#comment-17896841 ] Kirk True commented on KAFKA-16460: --- Looking at this in depth, there's an interesting

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

2024-11-08 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: -- Attachment: verifiable_consumer_worker_B.log verifiable_consumer_worker_A.log > New co

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

2024-11-08 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: -- Attachment: verifiable_consumer_worker_B.stdout verifiable_consumer_worker_A.stdout >

[jira] [Updated] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest

2024-11-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16176: -- Attachment: CLASSIC_group_protocol.log > Flaky test: testSendToPartitionWithFollowerShutdownShouldNotT

[jira] [Commented] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest

2024-11-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896836#comment-17896836 ] Kirk True commented on KAFKA-16176: --- [~apoorvmittal10]—I am getting this error when te

[jira] [Updated] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest

2024-11-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16176: -- Attachment: CONSUMER_group_protocol.log > Flaky test: testSendToPartitionWithFollowerShutdownShouldNot

[jira] [Updated] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest

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

[jira] [Updated] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest

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

[jira] [Updated] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest

2024-11-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-16176: -- Labels: integration-test (was: ) > Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeou

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

2024-11-08 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896832#comment-17896832 ] Kirk True commented on KAFKA-16460: --- And, of course, my very next system test run I ge

[jira] [Updated] (KAFKA-17964) TransactionsTest.testSendOffsetsWithGroupId fails with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17964: -- Description: When executing the {{{}TransactionsTest{}}}'s {{testSendOffsetsWithGroupId()}} using the

[jira] [Created] (KAFKA-17964) TransactionsTest.testSendOffsetsWithGroupId fails with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
Kirk True created KAFKA-17964: - Summary: TransactionsTest.testSendOffsetsWithGroupId fails with CONSUMER group protocol Key: KAFKA-17964 URL: https://issues.apache.org/jira/browse/KAFKA-17964 Project: Kaf

[jira] [Commented] (KAFKA-17961) TransactionsBounceTest.testWithGroupId fails with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896558#comment-17896558 ] Kirk True commented on KAFKA-17961: --- [~brandboat]—absolutely! :) > TransactionsBounce

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

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15402: -- Labels: (was: consumer) > Performance regression on close consumer after upgrading to 3.5.0 > --

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

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896539#comment-17896539 ] Kirk True commented on KAFKA-16460: --- I'm not seeing this reproduce in the last three r

[jira] [Commented] (KAFKA-17681) Fix unstable consumer_test.py#test_fencing_static_consumer

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896538#comment-17896538 ] Kirk True commented on KAFKA-17681: --- As an anecdote, I have not seen this occur for th

[jira] [Updated] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

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

[jira] [Updated] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17962: -- Description: The following failure is consistently seen when running {{{}test_pause_and_resume_sink.c

[jira] [Updated] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17962: -- Labels: kip-848-client-support (was: ) > test_pause_and_resume_sink fails with "Failed to consume mes

[jira] [Updated] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17962: -- Description: The following failure is consistently seen when running {{{}test_pause_and_resume_sink.c

[jira] [Updated] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17962: -- Fix Version/s: 4.0.0 (was: 0.10.2.0) > test_pause_and_resume_sink fails with "F

[jira] [Assigned] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-17962: - Assignee: (was: Kirk True) > test_pause_and_resume_sink fails with "Failed to consume messa

[jira] [Assigned] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-17962: - Assignee: Kirk True (was: Konstantine Karantasis) > test_pause_and_resume_sink fails with "Fai

[jira] [Updated] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17962: -- Affects Version/s: 3.9.0 > test_pause_and_resume_sink fails with "Failed to consume messages after >

[jira] [Created] (KAFKA-17962) test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
Kirk True created KAFKA-17962: - Summary: test_pause_and_resume_sink fails with "Failed to consume messages after resuming sink connector" with CONSUMER group protocol Key: KAFKA-17962 URL: https://issues.apache.org/ji

[jira] [Updated] (KAFKA-17961) TransactionsBounceTest.testWithGroupId fails with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17961: -- Description: When executing the {{TransactionsBounceTest}}'s {{testWithGroupId()}} using the {{CONSUM

[jira] [Created] (KAFKA-17961) TransactionsBounceTest.testWithGroupId fails with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
Kirk True created KAFKA-17961: - Summary: TransactionsBounceTest.testWithGroupId fails with CONSUMER group protocol Key: KAFKA-17961 URL: https://issues.apache.org/jira/browse/KAFKA-17961 Project: Kafka

[jira] [Updated] (KAFKA-17961) TransactionsBounceTest.testWithGroupId fails with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17961: -- Description: When executing the {{PlaintextAdminIntegrationTest}}'s {{testConsumerGroups()}} using th

[jira] [Updated] (KAFKA-17960) PlaintextAdminIntegrationTest.testConsumerGroups fails with CONSUMER group protocol

2024-11-07 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17960: -- Summary: PlaintextAdminIntegrationTest.testConsumerGroups fails with CONSUMER group protocol (was: Pl

[jira] [Created] (KAFKA-17960) PlaintextAdminIntegrationTest.testConsumerGroups fails when using AsyncKafkaConsumer

2024-11-07 Thread Kirk True (Jira)
Kirk True created KAFKA-17960: - Summary: PlaintextAdminIntegrationTest.testConsumerGroups fails when using AsyncKafkaConsumer Key: KAFKA-17960 URL: https://issues.apache.org/jira/browse/KAFKA-17960 Projec

[jira] [Assigned] (KAFKA-15284) Implement GroupProtocolResolver to dynamically determine consumer group protocol

2024-11-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15284: - Assignee: Kirk True > Implement GroupProtocolResolver to dynamically determine consumer group

[jira] [Updated] (KAFKA-17934) Add duration based offset reset option for consumer clients

2024-11-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17934: -- Component/s: clients consumer > Add duration based offset reset option for consumer c

[jira] [Updated] (KAFKA-17927) Disallow users to configure `max.in.flight.requests.per.connection` bigger than 5

2024-11-06 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17927: -- Component/s: clients producer > Disallow users to configure `max.in.flight.requests.

[jira] [Updated] (KAFKA-17182) Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer

2024-11-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17182: -- Summary: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer (was: Consumer fetch

[jira] [Updated] (KAFKA-17947) Update currentLag(), pause(), and resume() to perform logic in background thread

2024-11-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17947: -- Description: We have updated most of the {{AsyncKafkaConsumer}} API implementations to move the proce

[jira] [Updated] (KAFKA-17947) Update currentLag(), pause(), and resume() to update SubscriptionState in background thread

2024-11-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17947: -- Summary: Update currentLag(), pause(), and resume() to update SubscriptionState in background thread

[jira] [Created] (KAFKA-17947) Update currentLag(), pause(), and resume() to perform logic in background thread

2024-11-05 Thread Kirk True (Jira)
Kirk True created KAFKA-17947: - Summary: Update currentLag(), pause(), and resume() to perform logic in background thread Key: KAFKA-17947 URL: https://issues.apache.org/jira/browse/KAFKA-17947 Project: K

[jira] [Updated] (KAFKA-17947) Update currentLag(), pause(), and resume() to perform logic in background thread

2024-11-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17947: -- Labels: consumer-threading-refactor kip-848-client-support (was: ) > Update currentLag(), pause(), an

[jira] [Assigned] (KAFKA-15284) Implement GroupProtocolResolver to dynamically determine consumer group protocol

2024-11-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reassigned KAFKA-15284: - Assignee: (was: Kirk True) > Implement GroupProtocolResolver to dynamically determine consu

[jira] [Commented] (KAFKA-17518) AsyncKafkaConsumer cannot reliably leave group when closed with small timeout

2024-11-05 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895781#comment-17895781 ] Kirk True commented on KAFKA-17518: --- [~frankvicky]—can I have this task back? I believ

[jira] [Updated] (KAFKA-17732) System test coverage for new consumer positions getting behind committed offsets

2024-11-04 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17732: -- Summary: System test coverage for new consumer positions getting behind committed offsets (was: Syste

[jira] [Updated] (KAFKA-17925) Convert Kafka Client integration tests to use KRaft

2024-11-02 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17925: -- Description: Update pertinent integration tests to use KRaft and not Zookeeper. (was: Update quota, t

[jira] [Commented] (KAFKA-17625) Remove ZK from ducktape in 4.0

2024-11-02 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895071#comment-17895071 ] Kirk True commented on KAFKA-17625: --- There is some overlap between this ticket and KAF

[jira] [Updated] (KAFKA-17915) Convert Kafka Client system tests to use KRaft

2024-11-02 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-17915: -- Fix Version/s: 4.0.0 > Convert Kafka Client system tests to use KRaft > --

  1   2   3   4   5   6   7   8   9   10   >