How Kafka handle partition leader change?

Hi all I have a interesting question here. Let's say we have 2 broker B1 B2, controller C and producer P1, P2...Pn. Currently B1 holds the partition leader and Px is constantly producing messages to B1. We want to move the partition leadership to B2. How does the leadership change synced

Re: [VOTE] KIP-997: Partition-Level Throughput Metrics

@Matthias: yeah it should be 977, sorry for the confusion. Btw, do you want to cast another binding vote for it? Best, Qichao Chu On Fri, Nov 17, 2023 at 12:45 AM Matthias J. Sax wrote: > This is KIP-977, right? Not as the subject says. > > Guess we won't be able to fix this now. Hope it does

[VOTE] KIP-974: Docker Image for GraalVM based Native Kafka Broker

Hi, I'd like to call a vote on KIP-974 which aims to publish a docker image for GraalVM based Native Kafka Broker. KIP - https://cwiki.apache.org/confluence/display/KAFKA/KIP-974%3A+Docker+Image+for+GraalVM+based+Native+Kafka+Broker Discussion thread -

[jira] [Resolved] (KAFKA-15854) Move Java classes from kafka.server to the server module

[ https://issues.apache.org/jira/browse/KAFKA-15854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-15854. - Fix Version/s: 3.7.0 Resolution: Fixed > Move Java classes from kafka.server to the

Re: [DISCUSS] KIP-974 Docker Image for GraalVM based Native Kafka Broker

Hi, Thanks for the insightful feedback on this KIP. As there are no ongoing discussions, I'm considering moving into the voting process. Your continued input is greatly appreciated! Regards, Krishna On Fri, Sep 8, 2023 at 12:47 PM Krishna Agarwal < krishna0608agar...@gmail.com> wrote: > Hi, > I

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

See

[jira] [Created] (KAFKA-15856) Add integration tests for JoinGroup API and SyncGroup API

Dongnuo Lyu created KAFKA-15856: --- Summary: Add integration tests for JoinGroup API and SyncGroup API Key: KAFKA-15856 URL: https://issues.apache.org/jira/browse/KAFKA-15856 Project: Kafka

Re: [DISCUSS] KIP-954: expand default DSL store configuration to custom types

Hello Guozhang, Thanks for the feedback! For 1 there are tests verifying this and I did so manually as well, it does not reveal anything about the store types -- just the names, so I think we're good there. I've put an example at the bottom of this reply for people following the conversation.

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2394

See

[jira] [Created] (KAFKA-15855) RFC 9266: Channel Bindings for TLS 1.3 support | SCRAM-SHA-*-PLUS variants

Neustradamus created KAFKA-15855: Summary: RFC 9266: Channel Bindings for TLS 1.3 support | SCRAM-SHA-*-PLUS variants Key: KAFKA-15855 URL: https://issues.apache.org/jira/browse/KAFKA-15855 Project:

[jira] [Resolved] (KAFKA-14819) Publish a single kafka (aka core) Maven artifact in Apache Kafka 4.0 (KIP-897)

[ https://issues.apache.org/jira/browse/KAFKA-14819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-14819. - Fix Version/s: (was: 4.0.0) Resolution: Won't Fix As described in the KIP, we're