Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.2 #25

See

[jira] [Resolved] (KAFKA-13812) Kraft TopicsDelta finishSnapshot maybe loss data

[ https://issues.apache.org/jira/browse/KAFKA-13812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jacky resolved KAFKA-13812. --- Resolution: Not A Bug > Kraft TopicsDelta finishSnapshot maybe loss data >

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.1 #107

See

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

See

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.0 #197

See

[jira] [Created] (KAFKA-13812) Kraft TopicsDelta deletedTopicIds maybe loss data

jacky created KAFKA-13812: - Summary: Kraft TopicsDelta deletedTopicIds maybe loss data Key: KAFKA-13812 URL: https://issues.apache.org/jira/browse/KAFKA-13812 Project: Kafka Issue Type: Bug

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.2 #24

See

Re: Requesting permission for JIRA/Wiki

Correction: I would like to open a PR for https://issues.apache.org/jira/browse/KAFKA-12319 and not https://issues.apache.org/jira/browse/KAFKA-13530 as stated earlier. Divij Vaidya On Sat, Apr 9, 2022 at 12:19 AM Divij Vaidya wrote: > I would like to open a PR for >

Requesting permission for JIRA/Wiki

I would like to open a PR for https://issues.apache.org/jira/browse/KAFKA-13530 Please give me permission to: 1. create and assign JIRA items 2. create new cwiki JIRA username: divijvaidya cwiki username: divijvaidya Thank you. Regards, Divij Vaidya

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

See

[jira] [Created] (KAFKA-13811) Investigate sliding windows performance

Leah Thomas created KAFKA-13811: --- Summary: Investigate sliding windows performance Key: KAFKA-13811 URL: https://issues.apache.org/jira/browse/KAFKA-13811 Project: Kafka Issue Type: Task

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.1 #106

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.2 #23

See

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

See

Re: Requesting permissions to contribute to Apache Kafka.

Hi, Welcome to the Kafka community! I've granted you permissions on the wiki and jira. Thanks, Mickael On Fri, Apr 8, 2022 at 1:58 PM Evans Jahja wrote: > > Hi, my name is Evans Jahja. > > I'd like to contribute to Kafka. Please kindly add me. > > wiki: evans.jahja > jira: evans.jahja

[VOTE] 3.1.1 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 3.1.1. Apache Kafka 3.1.1 is a bugfix release and 29 issues have been fixed since 3.1.0. Release notes for the 3.1.1 release:

Re: [DISCUSS] KIP-827: Expose logdirs total and usable space via Kafka API

Thanks for replying. I still have a few lingering questions/comments. *Reg#1* Understood. I checked and the underlying system call is statvfs for unix systems which should be ok to call here. *Reg#2* Fair point. I checked again and yes, log.dir always means local storage even when tiered storage

[jira] [Resolved] (KAFKA-13809) FileStreamSinkConnector and FileStreamSourceConnector should propagate full configuration to tasks

[ https://issues.apache.org/jira/browse/KAFKA-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Urban resolved KAFKA-13809. -- Resolution: Won't Fix Connector configs are used for consumer/producer overrides, converter

[jira] [Created] (KAFKA-13810) Document behavior of KafkaProducer.flush() w.r.t callbacks

Karsten Spang created KAFKA-13810: - Summary: Document behavior of KafkaProducer.flush() w.r.t callbacks Key: KAFKA-13810 URL: https://issues.apache.org/jira/browse/KAFKA-13810 Project: Kafka

Get Kafka Error Codes on Producer send

Hi, I am trying to implement Kafka producers using Apache Camel. I want to know Kafka error codes (defined in Kafka protocol guide: ( https://kafka.apache.org/11/protocol.html#protocol_error_codes ) I also tried by writing Kafka producer in spring boot app, 1. used Producer Interceptor 2. Used

[jira] [Created] (KAFKA-13809) FileStreamSinkConnector and FileStreamSourceConnector should propagate full configuration to tasks

Daniel Urban created KAFKA-13809: Summary: FileStreamSinkConnector and FileStreamSourceConnector should propagate full configuration to tasks Key: KAFKA-13809 URL:

Requesting permissions to contribute to Apache Kafka.

Hi, my name is Evans Jahja. I'd like to contribute to Kafka. Please kindly add me. wiki: evans.jahja jira: evans.jahja

Re: [DISCUSS] KIP-827: Expose logdirs total and usable space via Kafka API

Hi Divij, Thanks for taking a look! 1. In order to retrieve the sizes, the plan is to use getTotalSpace() and getUsableSpace() from java.nio.file.FileStore. The implementations may vary depending on the filesystem but these calls typically don't depend on the size of storage but instead just

[jira] [Created] (KAFKA-13808) Mirrormaker2 stop sync data when modify topic partition in "Running a dedicated MirrorMaker cluster" mode

YANGLiiN created KAFKA-13808: Summary: Mirrormaker2 stop sync data when modify topic partition in "Running a dedicated MirrorMaker cluster" mode Key: KAFKA-13808 URL:

[DISCUSS] KIP-828: Add the corresponding validator to the configuration where the validator is missing

Hi devs, I've created a KIP that aims to add the corresponding validator to the config where the validator is missing. In order for the program to detect these incorrect configurations during initialization: