[jira] [Created] (KAFKA-17536) Ensure clear error message when "new" consumer used with incompatible cluster

2024-09-12 Thread Kirk True (Jira)
Kirk True created KAFKA-17536: - Summary: Ensure clear error message when "new" consumer used with incompatible cluster Key: KAFKA-17536 URL: https://issues.apache.org/jira/browse/KAFKA-17536 Project: Kafk

[jira] [Created] (KAFKA-17519) Review intended behavior of Consumer.close() and its timeout on interrupt

2024-09-10 Thread Kirk True (Jira)
Kirk True created KAFKA-17519: - Summary: Review intended behavior of Consumer.close() and its timeout on interrupt Key: KAFKA-17519 URL: https://issues.apache.org/jira/browse/KAFKA-17519 Project: Kafka

[jira] [Created] (KAFKA-17439) Make polling for new records an explicit action/event in the new consumer

2024-08-28 Thread Kirk True (Jira)
Kirk True created KAFKA-17439: - Summary: Make polling for new records an explicit action/event in the new consumer Key: KAFKA-17439 URL: https://issues.apache.org/jira/browse/KAFKA-17439 Project: Kafka

[jira] [Created] (KAFKA-17397) Ensure ClassicKafkaConsumer sends leave request on close even if interrupted

2024-08-21 Thread Kirk True (Jira)
Kirk True created KAFKA-17397: - Summary: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted Key: KAFKA-17397 URL: https://issues.apache.org/jira/browse/KAFKA-17397 Project: Kafka

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

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

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

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

[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] [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] [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] [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] [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] [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] [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] [Created] (KAFKA-17208) replica_scale_test.py fails for new consumer

2024-07-26 Thread Kirk True (Jira)
Kirk True created KAFKA-17208: - Summary: replica_scale_test.py fails for new consumer Key: KAFKA-17208 URL: https://issues.apache.org/jira/browse/KAFKA-17208 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-17182) Consumer's fetch sessions are evicted too quickly

2024-07-22 Thread Kirk True (Jira)
Kirk True created KAFKA-17182: - Summary: Consumer's fetch sessions are evicted too quickly Key: KAFKA-17182 URL: https://issues.apache.org/jira/browse/KAFKA-17182 Project: Kafka Issue Type: Bug

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

2024-07-22 Thread Kirk True (Jira)
Kirk True created KAFKA-17183: - Summary: New consumer system tests pass for subset of tests, but fail if running all tests Key: KAFKA-17183 URL: https://issues.apache.org/jira/browse/KAFKA-17183 Project:

[jira] [Created] (KAFKA-17060) Rename LegacyKafkaConsumer to ClassicKafkaConsumer

2024-07-01 Thread Kirk True (Jira)
Kirk True created KAFKA-17060: - Summary: Rename LegacyKafkaConsumer to ClassicKafkaConsumer Key: KAFKA-17060 URL: https://issues.apache.org/jira/browse/KAFKA-17060 Project: Kafka Issue Type: Impr

[jira] [Created] (KAFKA-17040) Unknown telemetry state: TERMINATED thrown when closing AsyncKafkaConsumer

2024-06-25 Thread Kirk True (Jira)
Kirk True created KAFKA-17040: - Summary: Unknown telemetry state: TERMINATED thrown when closing AsyncKafkaConsumer Key: KAFKA-17040 URL: https://issues.apache.org/jira/browse/KAFKA-17040 Project: Kafka

[jira] [Resolved] (KAFKA-16777) New consumer should throw NoOffsetForPartitionException on continuous poll zero if no reset strategy

2024-06-15 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16777. --- Reviewer: Bruno Cadonna Resolution: Fixed Resolved as part of fix for KAFKA-16637. > New cons

[jira] [Created] (KAFKA-16966) Allow offset commit fetch to reuse previous request if partitions are a subset

2024-06-14 Thread Kirk True (Jira)
Kirk True created KAFKA-16966: - Summary: Allow offset commit fetch to reuse previous request if partitions are a subset Key: KAFKA-16966 URL: https://issues.apache.org/jira/browse/KAFKA-16966 Project: Kaf

[jira] [Created] (KAFKA-16899) Rename MembershipManagerImpl's rebalanceTimeoutMs for clarity

2024-06-05 Thread Kirk True (Jira)
Kirk True created KAFKA-16899: - Summary: Rename MembershipManagerImpl's rebalanceTimeoutMs for clarity Key: KAFKA-16899 URL: https://issues.apache.org/jira/browse/KAFKA-16899 Project: Kafka Issu

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

2024-05-22 Thread Kirk True (Jira)
Kirk True created KAFKA-16818: - Summary: Move event-processing tests from ConsumerNetworkThreadTest to ApplicationEventProcessorTest Key: KAFKA-16818 URL: https://issues.apache.org/jira/browse/KAFKA-16818

[jira] [Resolved] (KAFKA-16578) Revert changes to connect_distributed_test.py for the new async Consumer

2024-05-21 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16578. --- Resolution: Won't Fix Most of the {{connect_distributed_test.py}} system tests were fixed, and {{te

[jira] [Created] (KAFKA-16787) Remove TRACE level logging from AsyncKafkaConsumer hot path

2024-05-16 Thread Kirk True (Jira)
Kirk True created KAFKA-16787: - Summary: Remove TRACE level logging from AsyncKafkaConsumer hot path Key: KAFKA-16787 URL: https://issues.apache.org/jira/browse/KAFKA-16787 Project: Kafka Issue

[jira] [Created] (KAFKA-16642) Update KafkaConsumerTest to show parameters in test lists

2024-04-29 Thread Kirk True (Jira)
Kirk True created KAFKA-16642: - Summary: Update KafkaConsumerTest to show parameters in test lists Key: KAFKA-16642 URL: https://issues.apache.org/jira/browse/KAFKA-16642 Project: Kafka Issue Typ

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

2024-04-29 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. --- Resolution: Duplicate > New consumer times out consuming records in consumer_test.py system test > -

[jira] [Resolved] (KAFKA-16609) Update parse_describe_topic to support new topic describe output

2024-04-26 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16609. --- Reviewer: Lucas Brutschy Resolution: Fixed > Update parse_describe_topic to support new topic

[jira] [Created] (KAFKA-16623) KafkaAsyncConsumer system tests warn about revoking partitions that weren't previously assigned

2024-04-25 Thread Kirk True (Jira)
Kirk True created KAFKA-16623: - Summary: KafkaAsyncConsumer system tests warn about revoking partitions that weren't previously assigned Key: KAFKA-16623 URL: https://issues.apache.org/jira/browse/KAFKA-16623

[jira] [Created] (KAFKA-16609) Update parse_describe_topic to support new topic describe output

2024-04-23 Thread Kirk True (Jira)
Kirk True created KAFKA-16609: - Summary: Update parse_describe_topic to support new topic describe output Key: KAFKA-16609 URL: https://issues.apache.org/jira/browse/KAFKA-16609 Project: Kafka I

[jira] [Resolved] (KAFKA-16462) New consumer fails with timeout in security_test.py system test

2024-04-23 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16462. --- Resolution: Duplicate > New consumer fails with timeout in security_test.py system test > --

[jira] [Resolved] (KAFKA-16464) New consumer fails with timeout in replication_replica_failure_test.py system test

2024-04-23 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16464. --- Resolution: Duplicate > New consumer fails with timeout in replication_replica_failure_test.py syste

[jira] [Created] (KAFKA-16579) Revert changes to consumer_rolling_upgrade_test.py for the new async Consumer

2024-04-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16579: - Summary: Revert changes to consumer_rolling_upgrade_test.py for the new async Consumer Key: KAFKA-16579 URL: https://issues.apache.org/jira/browse/KAFKA-16579 Project: Kafk

[jira] [Created] (KAFKA-16578) Revert changes to connect_distributed_test.py for the new async Consumer

2024-04-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16578: - Summary: Revert changes to connect_distributed_test.py for the new async Consumer Key: KAFKA-16578 URL: https://issues.apache.org/jira/browse/KAFKA-16578 Project: Kafka

[jira] [Created] (KAFKA-16577) New consumer fails with stop timeout in consumer_test.py’s test_consumer_bounce system test

2024-04-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16577: - Summary: New consumer fails with stop timeout in consumer_test.py’s test_consumer_bounce system test Key: KAFKA-16577 URL: https://issues.apache.org/jira/browse/KAFKA-16577

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

2024-04-17 Thread Kirk True (Jira)
Kirk True created KAFKA-16576: - Summary: New consumer fails with assert in consumer_test.py’s test_consumer_failure system test Key: KAFKA-16576 URL: https://issues.apache.org/jira/browse/KAFKA-16576 Proj

[jira] [Resolved] (KAFKA-16405) Mismatch assignment error when running consumer rolling upgrade system tests

2024-04-17 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16405. --- Reviewer: Lucas Brutschy Resolution: Fixed > Mismatch assignment error when running consumer r

[jira] [Created] (KAFKA-16565) IncrementalAssignmentConsumerEventHandler throws error when attempting to remove a partition that isn't assigned

2024-04-16 Thread Kirk True (Jira)
Kirk True created KAFKA-16565: - Summary: IncrementalAssignmentConsumerEventHandler throws error when attempting to remove a partition that isn't assigned Key: KAFKA-16565 URL: https://issues.apache.org/jira/browse/KAF

[jira] [Created] (KAFKA-16558) Implement HeartbeatRequestState.toStringBase()

2024-04-15 Thread Kirk True (Jira)
Kirk True created KAFKA-16558: - Summary: Implement HeartbeatRequestState.toStringBase() Key: KAFKA-16558 URL: https://issues.apache.org/jira/browse/KAFKA-16558 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-16557) Fix CommitRequestManager’s OffsetFetchRequestState.toString()

2024-04-15 Thread Kirk True (Jira)
Kirk True created KAFKA-16557: - Summary: Fix CommitRequestManager’s OffsetFetchRequestState.toString() Key: KAFKA-16557 URL: https://issues.apache.org/jira/browse/KAFKA-16557 Project: Kafka Issu

[jira] [Created] (KAFKA-16556) Race condition between ConsumerRebalanceListener and SubscriptionState

2024-04-15 Thread Kirk True (Jira)
Kirk True created KAFKA-16556: - Summary: Race condition between ConsumerRebalanceListener and SubscriptionState Key: KAFKA-16556 URL: https://issues.apache.org/jira/browse/KAFKA-16556 Project: Kafka

[jira] [Created] (KAFKA-16555) Consumer's RequestState has incorrect logic to determine if inflight

2024-04-15 Thread Kirk True (Jira)
Kirk True created KAFKA-16555: - Summary: Consumer's RequestState has incorrect logic to determine if inflight Key: KAFKA-16555 URL: https://issues.apache.org/jira/browse/KAFKA-16555 Project: Kafka

[jira] [Created] (KAFKA-16465) New consumer does not invoke rebalance callbacks as expected in consumer_test.py system test

2024-04-02 Thread Kirk True (Jira)
Kirk True created KAFKA-16465: - Summary: New consumer does not invoke rebalance callbacks as expected in consumer_test.py system test Key: KAFKA-16465 URL: https://issues.apache.org/jira/browse/KAFKA-16465

[jira] [Created] (KAFKA-16464) New consumer fails with timeout in replication_replica_failure_test.py system test

2024-04-02 Thread Kirk True (Jira)
Kirk True created KAFKA-16464: - Summary: New consumer fails with timeout in replication_replica_failure_test.py system test Key: KAFKA-16464 URL: https://issues.apache.org/jira/browse/KAFKA-16464 Project:

[jira] [Created] (KAFKA-16462) New consumer fails with timeout in security_test.py system test

2024-04-02 Thread Kirk True (Jira)
Kirk True created KAFKA-16462: - Summary: New consumer fails with timeout in security_test.py system test Key: KAFKA-16462 URL: https://issues.apache.org/jira/browse/KAFKA-16462 Project: Kafka Is

[jira] [Created] (KAFKA-16461) New consumer fails to consume records in security_test.py system test

2024-04-02 Thread Kirk True (Jira)
Kirk True created KAFKA-16461: - Summary: New consumer fails to consume records in security_test.py system test Key: KAFKA-16461 URL: https://issues.apache.org/jira/browse/KAFKA-16461 Project: Kafka

[jira] [Created] (KAFKA-16460) New consumer times out system test

2024-04-02 Thread Kirk True (Jira)
Kirk True created KAFKA-16460: - Summary: New consumer times out system test Key: KAFKA-16460 URL: https://issues.apache.org/jira/browse/KAFKA-16460 Project: Kafka Issue Type: Bug Compon

[jira] [Created] (KAFKA-16459) consumer_test.py’s static membership tests fail with new consumer

2024-04-02 Thread Kirk True (Jira)
Kirk True created KAFKA-16459: - Summary: consumer_test.py’s static membership tests fail with new consumer Key: KAFKA-16459 URL: https://issues.apache.org/jira/browse/KAFKA-16459 Project: Kafka

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

2024-03-28 Thread Kirk True (Jira)
Kirk True created KAFKA-16444: - Summary: Run KIP-848 unit tests under code coverage Key: KAFKA-16444 URL: https://issues.apache.org/jira/browse/KAFKA-16444 Project: Kafka Issue Type: Task

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

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

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

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

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

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

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

2024-03-28 Thread Kirk True (Jira)
Kirk True created KAFKA-16441: - Summary: Update streams_broker_down_resilience_test.py to support KIP-848’s group protocol config Key: KAFKA-16441 URL: https://issues.apache.org/jira/browse/KAFKA-16441 Pr

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

2024-03-28 Thread Kirk True (Jira)
Kirk True created KAFKA-16439: - Summary: Update replication_replica_failure_test.py to support KIP-848’s group protocol config Key: KAFKA-16439 URL: https://issues.apache.org/jira/browse/KAFKA-16439 Proje

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

2024-03-28 Thread Kirk True (Jira)
Kirk True created KAFKA-16438: - Summary: Update consumer_test.py’s static tests to support KIP-848’s group protocol config Key: KAFKA-16438 URL: https://issues.apache.org/jira/browse/KAFKA-16438 Project:

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

2024-03-28 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16271. --- Reviewer: Lucas Brutschy Resolution: Fixed > Update consumer_rolling_upgrade_test.py to suppor

[jira] [Resolved] (KAFKA-14246) Update threading model for Consumer

2024-03-25 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-14246. --- Resolution: Fixed > Update threading model for Consumer > --- > >

[jira] [Created] (KAFKA-16389) consumer_test.py’s test_valid_assignment fails with new consumer

2024-03-19 Thread Kirk True (Jira)
Kirk True created KAFKA-16389: - Summary: consumer_test.py’s test_valid_assignment fails with new consumer Key: KAFKA-16389 URL: https://issues.apache.org/jira/browse/KAFKA-16389 Project: Kafka I

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

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

[jira] [Created] (KAFKA-16315) Investigate propagating metadata updates via queues

2024-02-29 Thread Kirk True (Jira)
Kirk True created KAFKA-16315: - Summary: Investigate propagating metadata updates via queues Key: KAFKA-16315 URL: https://issues.apache.org/jira/browse/KAFKA-16315 Project: Kafka Issue Type: Tas

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

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

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

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

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

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

[jira] [Resolved] (KAFKA-16199) Prune the event queue if event timeout expired before starting

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16199. --- Resolution: Duplicate > Prune the event queue if event timeout expired before starting > ---

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

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

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

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

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

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16023. --- Resolution: Fixed {{testPerPartitionLagMetricsCleanUpWithSubscribe}} is now passing consistently, s

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

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

[jira] [Resolved] (KAFKA-16208) Design new Consumer timeout policy

2024-02-20 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16208. --- Resolution: Duplicate > Design new Consumer timeout policy > -- > >

[jira] [Created] (KAFKA-16287) Implement example test for common rebalance callback scenarios

2024-02-20 Thread Kirk True (Jira)
Kirk True created KAFKA-16287: - Summary: Implement example test for common rebalance callback scenarios Key: KAFKA-16287 URL: https://issues.apache.org/jira/browse/KAFKA-16287 Project: Kafka Iss

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Created] (KAFKA-16208) Design new Consumer timeout policy

2024-01-29 Thread Kirk True (Jira)
Kirk True created KAFKA-16208: - Summary: Design new Consumer timeout policy Key: KAFKA-16208 URL: https://issues.apache.org/jira/browse/KAFKA-16208 Project: Kafka Issue Type: Task Compo

[jira] [Created] (KAFKA-16200) Ensure RequestManager handling of expired timeouts are consistent

2024-01-26 Thread Kirk True (Jira)
Kirk True created KAFKA-16200: - Summary: Ensure RequestManager handling of expired timeouts are consistent Key: KAFKA-16200 URL: https://issues.apache.org/jira/browse/KAFKA-16200 Project: Kafka

[jira] [Created] (KAFKA-16199) Prune the event queue if events have expired before starting

2024-01-26 Thread Kirk True (Jira)
Kirk True created KAFKA-16199: - Summary: Prune the event queue if events have expired before starting Key: KAFKA-16199 URL: https://issues.apache.org/jira/browse/KAFKA-16199 Project: Kafka Issue

[jira] [Created] (KAFKA-16191) Clean up of consumer client internal events

2024-01-24 Thread Kirk True (Jira)
Kirk True created KAFKA-16191: - Summary: Clean up of consumer client internal events Key: KAFKA-16191 URL: https://issues.apache.org/jira/browse/KAFKA-16191 Project: Kafka Issue Type: Bug

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

2024-01-18 Thread Kirk True (Jira)
Kirk True created KAFKA-16167: - Summary: Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup Key: KAFKA-16167 URL: https://issues.apache.org/jira/browse/KAFKA-16167 Project: Kafka Issue Ty

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

2024-01-17 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16151. --- Resolution: Duplicate > Fix PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe >

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

2024-01-17 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16150. --- Resolution: Duplicate > Fix PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe > -

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

2024-01-16 Thread Kirk True (Jira)
Kirk True created KAFKA-16152: - Summary: Fix PlaintextConsumerTest.testStaticConsumerDetectsNewPartitionCreatedAfterRestart Key: KAFKA-16152 URL: https://issues.apache.org/jira/browse/KAFKA-16152 Project:

[jira] [Created] (KAFKA-16151) Fix PlaintextConsumerTest.testPerPartitionLedMetricsCleanUpWithSubscribe

2024-01-16 Thread Kirk True (Jira)
Kirk True created KAFKA-16151: - Summary: Fix PlaintextConsumerTest.testPerPartitionLedMetricsCleanUpWithSubscribe Key: KAFKA-16151 URL: https://issues.apache.org/jira/browse/KAFKA-16151 Project: Kafka

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

2024-01-16 Thread Kirk True (Jira)
Kirk True created KAFKA-16150: - Summary: Fix PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe Key: KAFKA-16150 URL: https://issues.apache.org/jira/browse/KAFKA-16150 Project: Kafka

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

2024-01-16 Thread Kirk True (Jira)
Kirk True created KAFKA-16149: - Summary: Aggressively expire unused client connections Key: KAFKA-16149 URL: https://issues.apache.org/jira/browse/KAFKA-16149 Project: Kafka Issue Type: Improveme

[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 Type:

  1   2   >