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

See

Re: [DISCUSS] Apache Kafka 3.5.1 release

Hi Divij, Thanks for volunteering! Luke On Wed, Jun 28, 2023 at 11:54 PM Manyanda Chitimbo < manyanda.chiti...@gmail.com> wrote: > Thank you Divij for volunteering to perform the release. > > On Wed 28 Jun 2023 at 13:52, Divij Vaidya wrote: > > > Hey folks > > > > Looks like we are ready to

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

See

Re: [DISCUSS] KIP-759: Unneeded repartition canceling

Hi all, Great discussion thread. May I take this KIP up? If it’s alright my plan is to update the KIP with the operator `markAsPartitioned()`. As you have discussed and pointed out, there are implications to downstream joins or aggregation operations. Still, the operator is intended for advanced

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

See Changes: -- [...truncated 579505 lines...] [INFO] --< org.apache.kafka:streams-quickstart-java >-- [INFO] Building streams-quickstart-java

[jira] [Resolved] (KAFKA-15078) When fetching offset 0 the KRaft leader should response with SnapshotId

[ https://issues.apache.org/jira/browse/KAFKA-15078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] José Armando García Sancio resolved KAFKA-15078. Fix Version/s: 3.6.0 Resolution: Fixed > When fetching

Final Reminder: Community Over Code call for presentations closing soon

[Note: You're receiving this email because you are subscribed to one or more project dev@ mailing lists at the Apache Software Foundation.] This is your final reminder that the Call for Presentations for Community Over Code (formerly known as ApacheCon) is closing soon - on Thursday, 13 July 2023

Re: [DISCUSS] KIP-933 Publish metrics when source connector fails to poll data

Hey Ravindra, Thanks for the KIP! It appears to be a useful addition to the metrics to understand poll related failures which can go untracked as of now. I just have a couple of minor comments: 1) Does it make sense to drop the *record *part from the metric name as it doesn't seem to serve much

[jira] [Resolved] (KAFKA-15028) AddPartitionsToTxnManager metrics

[ https://issues.apache.org/jira/browse/KAFKA-15028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan resolved KAFKA-15028. Resolution: Fixed > AddPartitionsToTxnManager metrics > -

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

See Changes: -- [...truncated 580468 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 > VersionedKeyValueStoreIntegrationTest >

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.5 #26

See

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

See Changes: -- [...truncated 525161 lines...] Gradle Test Run :core:integrationTest > Gradle Test Executor 170 > KafkaZkClientTest > testCreateTopLevelPaths() PASSED

[jira] [Created] (KAFKA-15133) RequestMetrics MessageConversionsTimeMs count is ticked even when no conversion occurs

Edoardo Comar created KAFKA-15133: - Summary: RequestMetrics MessageConversionsTimeMs count is ticked even when no conversion occurs Key: KAFKA-15133 URL: https://issues.apache.org/jira/browse/KAFKA-15133

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #179

See Changes: -- [...truncated 422017 lines...] /home/jenkins/workspace/Kafka_kafka_3.3/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:155: warning -

[jira] [Created] (KAFKA-15132) Implement disable & re-enablement for Tiered Storage

Divij Vaidya created KAFKA-15132: Summary: Implement disable & re-enablement for Tiered Storage Key: KAFKA-15132 URL: https://issues.apache.org/jira/browse/KAFKA-15132 Project: Kafka Issue

Re: [DISCUSS] Apache Kafka 3.5.1 release

Thank you Divij for volunteering to perform the release. On Wed 28 Jun 2023 at 13:52, Divij Vaidya wrote: > Hey folks > > Looks like we are ready to perform a release for 3.5.1 to provide a fix for > the vulnerability in snappy-java [1] > > I would like to volunteer as release manager for the

Re: [DISCUSS] KIP-916: MM2 distributed mode flow log context

If there are no further comments, I will kick off a vote soon for the KIP. Dániel Urbán ezt írta (időpont: 2023. jún. 12., H, 11:27): > Updated the KIP with a few example log lines before/after the change. > Daniel > > Dániel Urbán ezt írta (időpont: 2023. jún. 7., > Sze, 13:59): > >> Hi

Re: [DISCUSS] KIP-918: MM2 Topic And Group Listener

Hi Chris, Thank you for your comments, and sorry for the late reply. 1. Having a single, connector-reported metric for the topics, and another one for the groups sounds good to me. The only issue I see here is that I'm not familiar with any non-primitive metrics in the Kafka codebase, and don't

Re: [DISCUSS] Apache Kafka 3.5.1 release

Thanks for volunteering, Divij! On Wed, Jun 28, 2023 at 7:52 AM Divij Vaidya wrote: > Hey folks > > Looks like we are ready to perform a release for 3.5.1 to provide a fix for > the vulnerability in snappy-java [1] > > I would like to volunteer as release manager for the 3.5.1 release. > > If

Re: Offsets: consumption and production in rollback

Hi Henry, Consumers get to choose an isolation level. There’s one instance I can think of where AdminClient also has some ability to let users choose how to deal with uncommitted data. If you’ve not seen KIP-851 take a look:

[DISCUSS] Apache Kafka 3.5.1 release

Hey folks Looks like we are ready to perform a release for 3.5.1 to provide a fix for the vulnerability in snappy-java [1] I would like to volunteer as release manager for the 3.5.1 release. If there are no objections, I will start a release plan next Monday, on 3rd July. [1]

Re: [DISCUSS] KIP-940: Broker extension point for validating record contents at produce time

Hi Andrew, thanks for your comments ! Please see replies inline below. On Mon, 26 Jun 2023 at 16:51, Andrew Schofield wrote: > 4) For a new interface, I wonder whether it would be better to use > TopicIdPartition rather > than TopicPartition. Topic IDs are gradually spreading across the public

Re: [DISCUSS] KIP-940: Broker extension point for validating record contents at produce time

Hi Tom, thanks for tour comments, replies inline below. On Thu, 22 Jun 2023 at 10:58, Tom Bentley wrote: > > Hi Edorado and Adrian, > > Thanks for the KIP. > > I think it would be good to elaborate on exactly how validate() gets > called, because I think there are a number of potential

[jira] [Created] (KAFKA-15131) Improve RemoteStorageManager exception handling

Jorge Esteban Quilcate Otoya created KAFKA-15131: Summary: Improve RemoteStorageManager exception handling Key: KAFKA-15131 URL: https://issues.apache.org/jira/browse/KAFKA-15131

RE: Offsets: consumption and production in rollback

Hi Andrew, Thank you for your response. I understand your explanation, but in both cases, I am using an "isolation level" of READ_COMMITTED. I believe the issue lies in the AdminClient.listOffsets method, as it may not be considering the isolation level, where as the consumer of

[jira] [Created] (KAFKA-15130) Delete remote segments when delete a topic

Lan Ding created KAFKA-15130: Summary: Delete remote segments when delete a topic Key: KAFKA-15130 URL: https://issues.apache.org/jira/browse/KAFKA-15130 Project: Kafka Issue Type: Improvement

Re: [DISCUSS] KIP-944 Support async runtimes in consumer

It seems KIP-941 was already taken. Updated to: KIP-944. Op 28-06-2023 om 10:11 schreef Erik van Oosten: Hello developers of the Java based consumer, I submitted https://github.com/apache/kafka/pull/13914 to fix a long standing problem that the Kafka consumer on the JVM is not usable from

[DISCUSS] KIP-941 Support async runtimes in consumer

Hello developers of the Java based consumer, I submitted https://github.com/apache/kafka/pull/13914 to fix a long standing problem that the Kafka consumer on the JVM is not usable from asynchronous runtimes such as Kotlin co-routines and ZIO. However, since it extends the public API I was

[jira] [Created] (KAFKA-15129) Clean up all metrics that were forgotten to be closed

hudeqi created KAFKA-15129: -- Summary: Clean up all metrics that were forgotten to be closed Key: KAFKA-15129 URL: https://issues.apache.org/jira/browse/KAFKA-15129 Project: Kafka Issue Type:

Re: Apply to contribute to the Kafka project

Hi there! Thanks for your interest in contributing to Apache Kafka, you should be all set now. Let me know if there is any problem. Best, On Wed, Jun 28, 2023 at 9:47 AM isding_l wrote: > > Hi， > > > I'd like to request permissions to contribute to Kafka to propose a KIP. > > > Wiki ID:

Apply to contribute to the Kafka project

Hi， I'd like to request permissions to contribute to Kafka to propose a KIP. Wiki ID: isDing_L Kira ID: isDing_L Thank you -- 发自我的网易邮箱手机智能版