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

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

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

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.

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

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] [Created] (KAFKA-17960) PlaintextAdminIntegrationTest.testConsumerGroups fails when using AsyncKafkaConsumer

Kirk True created KAFKA-17960: - Summary: PlaintextAdminIntegrationTest.testConsumerGroups fails when using AsyncKafkaConsumer Key: KAFKA-17960 URL: https://issues.apache.org/jira/browse/KAFKA-17960

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

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

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

Kirk True created KAFKA-17925: - Summary: Convert Kafka Client integration tests to use KRaft Key: KAFKA-17925 URL: https://issues.apache.org/jira/browse/KAFKA-17925 Project: Kafka Issue Type

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

[ https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reopened KAFKA-15284: --- Assignee: Kirk True > Implement ConsumerGroupProtocolVersionResolver to determine consumer gr

[jira] [Created] (KAFKA-17823) Refactor GroupRebalanceConfig to remove unused configuration

Kirk True created KAFKA-17823: - Summary: Refactor GroupRebalanceConfig to remove unused configuration Key: KAFKA-17823 URL: https://issues.apache.org/jira/browse/KAFKA-17823 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reopened KAFKA-16444: --- > Run KIP-848 unit tests under code cover

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

[ https://issues.apache.org/jira/browse/KAFKA-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16444. --- Resolution: Won't Do > Run KIP-848 unit tests under code

Re: [VOTE] KIP-1092: Extend Consumer#close with an option to leave the group or not

Hi TengYao, +1 (non-binding) Thanks for all the work so far on this. Kirk On Mon, Oct 7, 2024, at 4:09 AM, TengYao Chi wrote: > Hi Andrew, > > Thanks for reviewing and participating in the vote. > I have corrected the issue as you pointed out. > > Sincerely, > TengYao > > Andrew Schofield 於

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

[ https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16272. --- Resolution: Fixed > Update connect_distributed_test.py to support KIP-848’s group protocol con

Re: [VOTE] KIP-1094 Add a new constructor method with nextOffsets to ConsumerRecords

+1 (non-binding) On Wed, Oct 2, 2024, at 12:41 PM, Alieh Saeedi wrote: > Hi all > > I would like to call a vote for KIP-1094. Please take a moment to review > the proposal and submit your vote. > > KIP: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1094%3A+Add+a+new+constructor+method+

[jira] [Created] (KAFKA-17686) PlaintextAdminIntegrationTest’s testOffsetsForTimesAfterDeleteRecords fails with NPE with new consumer

Kirk True created KAFKA-17686: - Summary: PlaintextAdminIntegrationTest’s testOffsetsForTimesAfterDeleteRecords fails with NPE with new consumer Key: KAFKA-17686 URL: https://issues.apache.org/jira/browse/KAFKA-17686

Re: [DISCUSS] KIP-1094 Add a new constructor method with nextOffsets to ConsumerRecords

Hi Alieh, Thanks for the KIP! Questions: KT1: In the second paragraph of the Motivation section, it mentions that in some cases the consumer does not return the correct next offset. Can you add a link to the bug here? I'm curious if that still happens with the "new" consumer. KT2: There's a c

Re: [DISCUSS] KIP-1092: Extend Consumer#close with an option to leave the group or not

irk On Mon, Sep 30, 2024, at 1:44 PM, Kirk True wrote: > Hi all, > > On Sun, Sep 29, 2024, at 12:08 PM, Chia-Ping Tsai wrote: > > > From an API POV, I think the new `CloseOptions` class should not have > > any "getters" and thus, it's irrelevant how we represe

Re: [DISCUSS] KIP-1092: Extend Consumer#close with an option to leave the group or not

Hi all, On Sun, Sep 29, 2024, at 12:08 PM, Chia-Ping Tsai wrote: > > From an API POV, I think the new `CloseOptions` class should not have > any "getters" and thus, it's irrelevant how we represent the different > cases in code internally (even if I believe using `Optional` might be a > good way t

Re: [DISCUSS] KIP-1092: Extend Consumer#close with an option to leave the group or not

antages: >>>> >>>> 1. It addresses the needs of Kafka Streams (if they start to use new >>>> consumer) >>>> 2. It simplifies the new coordinator, protocol, and consumer, as >> they no >>>> longer need to ha

Re: So long, Jenkins 👋

This is amazing work David! You leveled up every contributor and committer on the project. Thanks > On Sep 25, 2024, at 6:27 PM, Chris Egerton wrote: > > David, you're a legend. Thanks for spearheading this effort! > > On Wed, Sep 25, 2024, 20:51 David Arthur wrote: > >> Today, we disa

Re: [DISCUSS] KIP-1092: Extend Consumer#close with an option to leave the group or not

Hi TengYao, Thanks for writing up this KIP :) Questions: KT1: Why would a non-Kafka Streams application want to set leaveGroup=false? Because Kafka Streams manages the group membership assignment under the covers, it can re-assign partitions to a new Consumer when the old one closes. But in a

Re: [VOTE] KIP-1079: Deprecate `delete-config` of TopicCommand

Hi TengYao, +1 (non-binding). Using KAFKA-17087 to track the actual removal in 5.0 is going to help this not fall through the cracks. One minor point is that the description for the Jira states that "we should deprecate it in 3.9 and then remove it from 4.0” which should be "we should deprecat

Re: [VOTE] KIP-1082: Require Client-Generated IDs over the ConsumerGroupHeartbeat RPC

Hi TengYao, +1 (non-binding) Thanks for all the hard work with the tricky edge cases :) Kirk > On Sep 16, 2024, at 6:47 AM, TengYao Chi wrote: > > Hi everyone, > > Based on our discussion > > regarding KIP-1082

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

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

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

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

Re: [ANNOUNCE] New Kafka PMC Member: Josep Prat

Congratulations Josep! On Fri, Sep 6, 2024 at 11:06 AM Josep Prat wrote: > Thanks all!! > > -- > Josep Prat > Open Source Engineering Director, Aiven > josep.p...@aiven.io | +491715557497 | aiven.io > Aiven Deutschland GmbH > Alexanderufer 3-7, 10117 Berlin > Geschäftsführer:

Re: New release branch 3.9

g > > Chia-Ping Tsai 於 2024年8月30日 週五 上午9:32寫道： > >> hi Kirk >> >> KAFKA-17335 is already in 3.9 ( >> https://github.com/apache/kafka/commit/a87b501a47a55a1f9038b6c52e31b71590c3a80a >> ) >> >> Best, >> Chia-Ping >> >> K

Re: New release branch 3.9

Hi Colin, KAFKA-17335 (Lack of default for URL encoding configuration for OAuth causes NPE) affects the internal use of the OAuth-based AuthenticateCallbackHandler. Can we back port the fix (https://github.com/apache/kafka/pull/16990) to the 3.9 branch? Thanks, Kirk > On Aug 29, 2024, at 11:2

Re: [DISCUSS] KIP-1082: Enable ID Generation for Clients over the ConsumerGroupHeartbeat RPC

Hi TengYao! Sorry for being late to the discussion... After reading the thread and then the KIP, I had a few questions/comments: KT1: In Motivation, it states: "This scenario can result in the broker registering a new member for which it will never receive a proper leave request.” Just to be c

Re: [DISCUSS] KIP-1086: Add ability to specify a custom produce request parser.

Hi Maxim, Thanks for the KIP! This is not my area, but I have some questions/comments: 1. CMIIW, but I believe that specifying this custom parser class should be done via configuration, not system properties or environment variables, right? 2. What happens if the custom parser can’t be loaded?

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

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

Re: [ANNOUNCE] New committer: Lianet Magrans

Congratulations Lianet On Wed, Aug 28, 2024, at 9:47 AM, Bruno Cadonna wrote: > Well deserved! > > Best, > Bruno > > On 8/28/24 6:37 PM, Bill Bejeck wrote: > > Congrats Lianet! > > > > On Wed, Aug 28, 2024 at 12:32 PM Matthias J. Sax wrote: > > > >> Congrats! Very well deserved! > >>

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

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

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

[ 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 St

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

[ 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 St

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

[ 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 St

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

[ 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 consu

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

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

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

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

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

[ 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

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

[ 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

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

[ 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

[ 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

[ 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

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

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

Re: [DISCUSS] Graduation steps for Features

Hi Josep, Thanks for starting this conversation! Yes, for KIPs that span multiple releases, clearly defining the KIP’s state for each release is very important. Perhaps the KIP template could be updated to include a “Release Plan” section that includes entries that include: - Version: future A

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

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

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

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

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

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

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

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

Re: [DISCUSS] KIP-1059: Enable the Producer flush() method to clear the latest send() error

Hi Matthias, > On Jun 21, 2024, at 12:28 PM, Matthias J. Sax wrote: > > If we want to limit it to `RecordTooLargeException` throwing from `send()` > directly make sense. Thanks for calling it out. > > It's still a question of backward compatibility? `send()` does throw > exceptions already, i

Re: [DISCUSS] KIP-1059: Enable the Producer flush() method to clear the latest send() error

Hi all, The JavaDoc for Producer.flush() states: Applications don't need to call this method for transactional producers, since the commitTransaction() will flush all buffered records before performing the commit. This ensures that all the send() calls made since the previous beginTransaction(

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

[ 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. >

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

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

Re: [DISCUSS] KIP-1043: Administration of groups

Hi Andrew, Thanks for the KIP! I don’t have much experience as a Kafka operator, but this seems like a very sane proposal. Questions & comments: 1. Do you think the ListGroupsResult.all() method is a bit of a potential ‘foot gun’? I can imagine cases where developers reach for that without und

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

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:

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

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

[ 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

Re: [VOTE] KIP-1038: Add Custom Error Handler to Producer

+1 (non-binding) Thanks Alieh! > On May 20, 2024, at 6:00 AM, Walker Carlson > wrote: > > Hey Alieh, > > Thanks for the KIP. > > +1 binding > > Walker > > On Tue, May 7, 2024 at 10:57 AM Alieh Saeedi > wrote: > >> Hi all, >> >> It seems that we have no more comments, discussions, or fee

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

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

Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception

+1 (non-binding) Thanks Fred! > On May 13, 2024, at 5:46 AM, Bill Bejeck wrote: > > Thanks for the KIP! > > +1 (binding) > > -Bill > > > On Tue, May 7, 2024 at 6:16 PM Sophie Blee-Goldman > wrote: > >> +1 (binding) >> >> thanks for the KIP! >> >> On Fri, May 3, 2024 at 9:13 AM Matthias

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

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

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

[ 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 t

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

[ 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 to

Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer

eating more problems than we are solving. It is still unclear to me how >> we expect to handle the errors. Perhaps we could include an example? It >> seems like there is a specific use case in mind and maybe we can make a >> design that is tighter and supports that case. >> &g

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

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-

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

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

Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer

Hi Alieh, Thanks for the KIP! A few questions: K1. What is the expected behavior for the producer if it generates a RecordTooLargeException, but the handler returns RETRY? K2. How do we determine which Record was responsible for the UnknownTopicOrPartitionException since we get that response w

Re: [DISCUSS] KIP-1036: Extend RecordDeserializationException exception

Hi Fred, Thanks for the updates! Questions: K11. Can we reconsider the introduction of two new exception subclasses? Perhaps I don’t understand the benefit? Technically both the key and the value could have deserialization errors, right? K12. Is there a benefit to exposing both the ByteBuffer

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

[ 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 t

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

[ 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

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

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

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

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

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

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

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

[ 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 consu

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

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/b

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

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()

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

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

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

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:

Re: [DISCUSS] KIP-1036: Extend RecordDeserializationException exception

Hi Fred, Thanks for the KIP! Questions/comments: How do we handle the case where CompletedFetch.parseRecord isn’t able to construct a well-formed ConsumerRecord (i.e. the values it needs are missing/corrupted/etc.)? Please change RecordDeserializationException’s getConsumerRecord() method to b

Re: [VOTE] KIP-1025: Optionally URL-encode clientID and clientSecret in authorization header

+1 (non-binding) Apologies. I thought I’d already voted :( > On Apr 7, 2024, at 10:48 AM, Nelson B. wrote: > > Hi all, > > Just wanted to bump up this thread for visibility. > > Thanks! > > On Thu, Mar 28, 2024 at 3:40 AM Doğuşcan Namal > wrote: > >> Thanks for checking it out Nelson. Yeah

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[ 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

Re: [ANNOUNCE] New committer: Christo Lolov

Congratulations Christo! > On Mar 26, 2024, at 7:27 AM, Satish Duggana wrote: > > Congratulations Christo! > > On Tue, 26 Mar 2024 at 19:20, Ivan Yurchenko wrote: >> >> Congrats! >> >> On Tue, Mar 26, 2024, at 14:48, Lucas Brutschy wrote: >>> Congrats! >>> >>> On Tue, Mar 26, 2024 at 2:44 P

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

[ 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 Consu

  1   2   3   4   >