Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.3 #173

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1814

See Changes: -- [...truncated 567195 lines...] [Pipeline] } [Pipeline] // stage [Pipeline] } [2023-05-02T22:01:28.928Z] [2023-05-02T22:01:28.928Z] > Task

[jira] [Created] (KAFKA-14960) Metadata Request Manager and listTopics/partitionsFor API

Philip Nee created KAFKA-14960: -- Summary: Metadata Request Manager and listTopics/partitionsFor API Key: KAFKA-14960 URL: https://issues.apache.org/jira/browse/KAFKA-14960 Project: Kafka Issue

Re: [DISCUSS] KIP-923: Add A Grace Period to Stream Table Join

Cool KIP, Walker! Thanks for sharing this proposal. A few clarifications: 1. Is the order that records exit the buffer in necessarily the same as the order that records enter the buffer in, or no? Based on the description in the KIP, it sounds like the answer is no, i.e., records will exit the

Re: Kafka client needs KAFKA-10337 to cover async commit use case

Sorry - I dug a bit into the old PR. Seems like the issue is there's broken contract that if the commitSync won't wait for the previous async commits to complete if it tries to commit an empty offset map. On Tue, May 2, 2023 at 12:49 PM Philip Nee wrote: > Hey Erik, > > Just a couple of

Re: Kafka client needs KAFKA-10337 to cover async commit use case

Hey Erik, Just a couple of questions to you: Firstly, could you explain the situation in that you would prefer to invoke commitAsync over commitSync in the rebalance listener? Typically we would use the synchronized method to ensure the commits are completed before moving on with the

Kafka client needs KAFKA-10337 to cover async commit use case

Dear developers of the Kafka java client, It seems I have found a feature gap in the Kafka java client. KAFKA-10337 and its associated pull request on Github (from 2020!) would solve this, but it was closed without merging. We would love to see it being reconsidered for merging. This mail has

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #1813

See

[jira] [Created] (KAFKA-14959) Remove metrics on ClientQuota Managers shutdown

Manyanda Chitimbo created KAFKA-14959: - Summary: Remove metrics on ClientQuota Managers shutdown Key: KAFKA-14959 URL: https://issues.apache.org/jira/browse/KAFKA-14959 Project: Kafka

[jira] [Created] (KAFKA-14958) Investigate enforcing all batches have the same producer ID

Justine Olshan created KAFKA-14958: -- Summary: Investigate enforcing all batches have the same producer ID Key: KAFKA-14958 URL: https://issues.apache.org/jira/browse/KAFKA-14958 Project: Kafka

[jira] [Created] (KAFKA-14957) Default value for state.dir is confusing

Mickael Maison created KAFKA-14957: -- Summary: Default value for state.dir is confusing Key: KAFKA-14957 URL: https://issues.apache.org/jira/browse/KAFKA-14957 Project: Kafka Issue Type: Bug

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.4 #119

See Changes: -- [...truncated 524210 lines...] [2023-05-02T15:41:58.270Z]

Re: [DISCUSS] Apache Kafka 3.5.0 release

Hi Luke, Yes I think it makes sense to backport both to 3.5. Thanks, Mickael On Tue, May 2, 2023 at 11:38 AM Luke Chen wrote: > > Hi Mickael, > > There are 1 bug and 1 improvement that I'd like to backport to 3.5. > 1. A small improvement for ZK migration based on KAFKA-14840 (mentioned >

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #1812

See

[jira] [Created] (KAFKA-14956) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted

Sagar Rao created KAFKA-14956: - Summary: Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted Key: KAFKA-14956 URL:

[jira] [Created] (KAFKA-14955) Validate that all partitions are assigned in TargetAssignmentBuilder

David Jacot created KAFKA-14955: --- Summary: Validate that all partitions are assigned in TargetAssignmentBuilder Key: KAFKA-14955 URL: https://issues.apache.org/jira/browse/KAFKA-14955 Project: Kafka

Re: [DISCUSS] KIP-892: Transactional Semantics for StateStores

Hi Nick, Thanks for the updates! I have a couple of questions/comments. 1. Why do you propose a configuration that involves max. bytes and max. reords? I think we are mainly concerned about memory consumption because we want to limit the off-heap memory used. I cannot think of a case where

Re: [ANNOUNCE] New PMC chair: Mickael Maison

Congratulations Mickael !! On Mon, 24 Apr 2023 at 20:18, Randall Hauch wrote: > Thank you, Jun, for all your contributions as PMC chair. > > And congratulations and thanks, Mickael, for volunteering to take over this > important role. > > Best regards, > Randall > > On Mon, Apr 24, 2023 at 1:39 

[jira] [Created] (KAFKA-14954) Use BufferPools to optimize allocation in RemoteLogInputStream

Divij Vaidya created KAFKA-14954: Summary: Use BufferPools to optimize allocation in RemoteLogInputStream Key: KAFKA-14954 URL: https://issues.apache.org/jira/browse/KAFKA-14954 Project: Kafka

[jira] [Created] (KAFKA-14953) Add metrics for expiration of delayed remote fetch

Divij Vaidya created KAFKA-14953: Summary: Add metrics for expiration of delayed remote fetch Key: KAFKA-14953 URL: https://issues.apache.org/jira/browse/KAFKA-14953 Project: Kafka Issue

Re: [DISCUSS] Apache Kafka 3.5.0 release

Hi Mickael, There are 1 bug and 1 improvement that I'd like to backport to 3.5. 1. A small improvement for ZK migration based on KAFKA-14840 (mentioned above in David's mail). PR is already merged to trunk. https://issues.apache.org/jira/browse/KAFKA-14909 2. A bug will cause the KRaft