Need help with kafka contribution

Hi, I am a newbie contributing to kafka. Worked on below basic JIRA issues. Whom should I ask for a review? https://issues.apache.org/jira/browse/KAFKA-19399 https://issues.apache.org/jira/browse/KAFKA-19395 GitHub PR - https://github.com/apache/kafka/pull/19943 Thanks!

[jira] [Created] (KAFKA-19402) Typo in EventAccumulator.java

Mason Chen created KAFKA-19402: -- Summary: Typo in EventAccumulator.java Key: KAFKA-19402 URL: https://issues.apache.org/jira/browse/KAFKA-19402 Project: Kafka Issue Type: Task Componen

[jira] [Resolved] (KAFKA-19359) [8.8] [CVE-2025-48734] [commons-beanutils] [1.9.4]

[ https://issues.apache.org/jira/browse/KAFKA-19359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-19359. --- Fix Version/s: 3.9.2 4.0.1 4.1.0 Resolution: Fixed > [8

Re: [PR] MINOR: Update 3.9.1 site [kafka-site]

frankvicky commented on PR #687: URL: https://github.com/apache/kafka-site/pull/687#issuecomment-2964859249 I will take a look -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

[jira] [Created] (KAFKA-19401) Consider keeping/removing the internal wrappers from streams module

Chia-Ping Tsai created KAFKA-19401: -- Summary: Consider keeping/removing the internal wrappers from streams module Key: KAFKA-19401 URL: https://issues.apache.org/jira/browse/KAFKA-19401 Project: Kafk

Re: KafkaProducer partitionsFor v/s KafkaAdminClient describeTopics

Hi Anana, Typically in Kafka, it is useful for Consumers to know about the number of partitions (as the number of consumers must be <= partitions). So one way for Consumers to find partitions is the KafkaConsumer class using the partitionsFor(topic) method, https://kafka.apache.org/40/javadoc/o

Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor

I totally understand the concerns regarding internal classes, but they have been introduced to the streams module for a while, including AutoOffsetResetInternal, JoinWindowsInternal, NamedInternal, and ToInternal. Obstructing this KIP solely due to a 'code taste' issue may not be worthwhile, so

Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor

hi Sophie I totally understand the concerns regarding internal classes, but they have been introduced to the streams module for a while, including AutoOffsetResetInternal, JoinWindowsInternal, NamedInternal, and ToInternal. Obstructing this KIP solely due to a code taste may not be worthwhile,

Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor

Sorry I didn't see this in time but we actually ended up removing the CloseOptionsInternal in the consumer version of this API. And I personally prefer this approach, especially for such a small and simple class -- feels silly to create a new separate class just to hide two methods that don't mutat

Re: [VOTE] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology

Thanks for the KIP! +1 (binding) -Bill On Wed, Jun 11, 2025 at 6:41 PM Sophie Blee-Goldman wrote: > +1 (binding) > > thanks for the KIP! > > On Tue, Jun 10, 2025 at 4:16 AM Sebastien Viale < > sebastien.vi...@michelin.com> wrote: > > > Hi, > > > > I'd like to start a for KIP-1138 Clean up Top

Re: [VOTE] KIP-1153: Refactor Kafka Streams CloseOptions to Fluent API Style

+1 (binding) Thanks! On Wed, Jun 11, 2025 at 2:39 PM Bill Bejeck wrote: > Thanks for the KIP! Nice addition to the API, > > +1(binding) > > -Bill > > On Wed, Jun 11, 2025 at 5:18 PM Matthias J. Sax wrote: > > > Sorry for the delay. LGTM. > > > > +1 (binding) > > > > > > -Matthias > > > > On 5/

Re: [VOTE] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology

+1 (binding) thanks for the KIP! On Tue, Jun 10, 2025 at 4:16 AM Sebastien Viale < sebastien.vi...@michelin.com> wrote: > Hi, > > I'd like to start a for KIP-1138 Clean up TopologyConfig and API for > supplying configs needed by the topology : > > https://cwiki.apache.org/confluence/display/KAFK

Re: [VOTE] KIP-1153: Refactor Kafka Streams CloseOptions to Fluent API Style

Thanks for the KIP! Nice addition to the API, +1(binding) -Bill On Wed, Jun 11, 2025 at 5:18 PM Matthias J. Sax wrote: > Sorry for the delay. LGTM. > > +1 (binding) > > > -Matthias > > On 5/20/25 5:38 AM, 黃竣陽 wrote: > > Hello all, > > > > I would like to call a vote on KIP-1153: Refactor Kafka

Re: [DISCUSS] KIP-1027 Add MockFixedKeyProcessorContext

Is there still interest to complete this KIP? -Matthias On 8/26/24 5:06 AM, Lucas Brutschy wrote: Hi everybody, this KIP is looking good to me. Just note that the release version is set to 3.8 and should probably be updated. Are we ready to open a vote on this one? I do not have any additiona

Re: [VOTE] KIP-1153: Refactor Kafka Streams CloseOptions to Fluent API Style

Sorry for the delay. LGTM. +1 (binding) -Matthias On 5/20/25 5:38 AM, 黃竣陽 wrote: Hello all, I would like to call a vote on KIP-1153: Refactor Kafka Streams CloseOptions to Fluent API Style KIP: Discussion thread:

Re: [DISCUSS] Apache Kafka 4.1.0 release

Hi Mickael, Thanks for working on the release. I have a PR for faster HWM propagation for the kraft cluster metadata partition. I expect the PR to get merged this week. Can I cherry pick it to the 4.1 branch when it is merged? PR: https://github.com/apache/kafka/pull/19800 Thanks, On Tue, Jun 1

[DISCUSS] KIP-1186: Update AddRaftVoterRequest RPC to support auto-join

Hello all, I wrote a KIP to add a new boolean field to the AddRaftVoterRequest RPC. Here is the link: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1186%3A+Update+AddRaftVoterRequest+RPC+to+support+auto-join Thanks, Kevin Wu

RE: [VOTE] KIP-1121: Compression acceleration in Kafka

Hello all, I would like to call a vote for KIP-1121. This KIP introduces a simple framework that enables the use of alternative, faster implementations of the existing compression codecs (Gzip, Snappy, Zstandard and LZ4) in Kafka. https://cwiki.apache.org/confluence/x/Xgr0Ew Thanks -O

Re: [PR] MINOR: Update 3.9.1 site [kafka-site]

mimaison commented on PR #687: URL: https://github.com/apache/kafka-site/pull/687#issuecomment-2963811266 This overwrote a bunch of updates we had made to `39/ops.html`: https://github.com/apache/kafka-site/commit/dfe950b0d833ca440ea886c88b7ad31a5972a7c4#diff-2935bbc848956768b4752c6bc57df937

Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology

Thanks Lucas, good catch indeed, I just updated it. Cheers Sébastien De : Lucas Brutschy Date : mercredi, 11 juin 2025 à 15:09 À : dev@kafka.apache.org Objet : [EXT] Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Warning External sender Do

Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology

Hi Sebastien, A constructor for Map and Properties each looks good to me. Thanks for the update to the KIP. -Bill On Wed, Jun 11, 2025 at 8:16 AM Lucas Brutschy wrote: > Hi Sebastien, > > having both Map/Properties sounds good to me. > > In the example in under `New way to pass topology-specif

[jira] [Resolved] (KAFKA-18666) Controller-side monitoring for broker shutdown and startup

[ https://issues.apache.org/jira/browse/KAFKA-18666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Wu resolved KAFKA-18666. -- Resolution: Fixed > Controller-side monitoring for broker shutdown and startup > -

Re: Please add me to the group

Hi, Subscription is self served. See the instructions in https://kafka.apache.org/contact Thanks, Mickael On Wed, Jun 11, 2025 at 3:47 PM Vinothini A wrote: > >

[jira] [Created] (KAFKA-19400) Update AddRaftVoterRPC to support controller auto-joining

Kevin Wu created KAFKA-19400: Summary: Update AddRaftVoterRPC to support controller auto-joining Key: KAFKA-19400 URL: https://issues.apache.org/jira/browse/KAFKA-19400 Project: Kafka Issue Type:

Please add me to the group

Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology

Hi Sebastien, having both Map/Properties sounds good to me. In the example in under `New way to pass topology-specific config:`, you still seem to use the `StreamConfig` constructor. Could you update the example as well? Cheers, Lucas On Fri, May 23, 2025 at 3:32 PM Sebastien Viale wrote: > >

Re: KafkaProducer partitionsFor v/s KafkaAdminClient describeTopics

Thanks for the response Ziming. In our case, we have a requirement that some users may have kafka setup where they can only produce and consume. But not be able to invoke the admin client. Hence we are going for the use of partitionsFor API in kafka producer and consumer. On Wed, Jun 11, 2025 at

Re: [DISCUSS] KIP-1172: Improve EndToEndLatency tool

Hi Chia-Ping Thanks for the feedback! chia_0: Good suggestion! I've expanded the "Compatibility" section to include more detailed e2e testing descriptions. chia_1: Exactly—the new fields only work with the new argument parser. I've made this explicit in the KIP to avoid any confusion. chia_2:

[jira] [Reopened] (KAFKA-19332) Fix flaky test : testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck and testAlterReadCommittedToReadUncommittedIsolationLevelWithRejectAck

[ https://issues.apache.org/jira/browse/KAFKA-19332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shivsundar R reopened KAFKA-19332: -- > Fix flaky test : > testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck and > t

Re: [VOTE] KIP-1157: Enforce KafkaPrincipalSerde Implementation for KafkaPrincipalBuilder

+1 (binding) from me. Thanks. Luke On Wed, Jun 11, 2025 at 5:46 PM TengYao Chi wrote: > +1 (binding) > > Best, > TengYao > > Kuan Po Tseng 於 2025年5月30日 週五 下午4:27寫道： > > > > +1 (non-binding), thanks for the KIP! > > > > On 2025/05/05 08:03:12 Johnny Wang wrote: > > > Hi all, > > > I would like

Re: [VOTE] KIP-1157: Enforce KafkaPrincipalSerde Implementation for KafkaPrincipalBuilder

+1 (binding) Best, TengYao Kuan Po Tseng 於 2025年5月30日 週五 下午4:27寫道： > > +1 (non-binding), thanks for the KIP! > > On 2025/05/05 08:03:12 Johnny Wang wrote: > > Hi all, > > I would like to call a vote for KIP-1157. > > https://cwiki.apache.org/confluence/x/1gq9F > > > > This KIP proposes to enforc