Re: [VOTE] KIP-950: Tiered Storage Disablement

Hi Kamal, Thanks for the comments. For this: > If we throw an exception from the server for invalid config, then there will be inconsistency between the CLI tools and the actual state of the topic in the cluster. This can cause some confusion to the users whether tiered storage is disabled or not

[jira] [Created] (KAFKA-17205) Allow topic config validation in controller level

Luke Chen created KAFKA-17205: - Summary: Allow topic config validation in controller level Key: KAFKA-17205 URL: https://issues.apache.org/jira/browse/KAFKA-17205 Project: Kafka Issue Type: Sub-

Re: [VOTE] KIP-1068: New metrics for the new KafkaConsumer

HI Brenden, Thanks for the KIP. +1 (non-binding) Thanks, Andrew > On 25 Jul 2024, at 23:26, Apoorv Mittal wrote: > > Hi Brenden, > The metrics look good. Thanks for the KIP. > > +1 (Non-Binding) > > Regards, > Apoorv Mittal > > > On Thu, Jul 25, 2024 at 5:04 PM Philip Nee > wrote: > >> Hi Bren

Re: [VOTE] KIP-950: Tiered Storage Disablement

Luke, Thanks for confirming the topic config change validation on the controller and updating the KIP. The updated KIP LGTM. 1. Can we update the below sentence in the KIP to clarify that remote.storage.enable should be true during graceful disablement? > Users set the configuration "remote.stor

Re: [VOTE] KIP-950: Tiered Storage Disablement

Thanks Kamal for the comments. KIP updated. Thanks. Luke On Fri, Jul 26, 2024 at 6:56 PM Kamal Chandraprakash < kamal.chandraprak...@gmail.com> wrote: > Luke, > > Thanks for confirming the topic config change validation on the controller > and updating the KIP. > The updated KIP LGTM. > > 1. Can

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

See

Queries regarding kafka logs

Hi, I am facing issue with kafka logs clearing. Please take this to development team i want to discuss with them. Issue :kafka server is running,kafka consumer is running is running in a wpf application, a batch file to delete kafka logs is running for every one hour from task scheduler at tha

Re: [VOTE] 3.8.0 RC3

Thank you all who reviewed this release candidate and the previous ones. This vote passes with 7 +1 votes (3 bindings) and no 0 or -1 votes. +1 votes PMC Members: * Chris Egerton * Greg Harris * Mickael Maison Committers: * Igor Soarez Community: * Murali Basani * Jakub Scholz * Krishna Agarwal

[jira] [Created] (KAFKA-17206) Use v1 of LeaderChangeMessage when kraft.version is 1

Alyssa Huang created KAFKA-17206: Summary: Use v1 of LeaderChangeMessage when kraft.version is 1 Key: KAFKA-17206 URL: https://issues.apache.org/jira/browse/KAFKA-17206 Project: Kafka Issue T

[jira] [Resolved] (KAFKA-17204) KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17204. - Fix Version/s: 3.9.0 Resolution: Fixed > KafkaStreamsCloseOptionsIntegrationTest.

[PR] Minor update website 38 release [kafka-site]

jlprat opened a new pull request, #616: URL: https://github.com/apache/kafka-site/pull/616 Add the banner for older versions. Links the pages to the new version -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

Re: [VOTE] KIP-1070: Deprecate MockProcessorContext

I updated the KIP accordingly. If there is no further follow usp, I'll close the vote shortly. -Matthias On 7/21/24 10:24 PM, Matthias J. Sax wrote: I just realized that both - ValueTransformerWithKey and - ValueTransfromerWithKeySupplier are still used by non-deprecated `KTable#transformVa

Re: [VOTE] KIP-1068: New metrics for the new KafkaConsumer

Thanks for the KIP Brenden. +1 (binding) On 7/26/24 1:16 AM, Andrew Schofield wrote: HI Brenden, Thanks for the KIP. +1 (non-binding) Thanks, Andrew On 25 Jul 2024, at 23:26, Apoorv Mittal wrote: Hi Brenden, The metrics look good. Thanks for the KIP. +1 (Non-Binding) Regards, Apoorv Mit

Re: [VOTE] KIP-1068: New metrics for the new KafkaConsumer

Hi Brenden, Thanks for the KIP! +1(binding) -Bill On Fri, Jul 26, 2024 at 1:54 PM Matthias J. Sax wrote: > Thanks for the KIP Brenden. > > +1 (binding) > > On 7/26/24 1:16 AM, Andrew Schofield wrote: > > HI Brenden, > > Thanks for the KIP. > > > > +1 (non-binding) > > > > Thanks, > > Andrew >

[jira] [Created] (KAFKA-17207) ConnectWorkerIntegrationTest.testRequestTimeouts times out in stop(), leaking clients

Greg Harris created KAFKA-17207: --- Summary: ConnectWorkerIntegrationTest.testRequestTimeouts times out in stop(), leaking clients Key: KAFKA-17207 URL: https://issues.apache.org/jira/browse/KAFKA-17207 P

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

See Changes: -- [...truncated 406639 lines...] [2024-07-26T18:55:21.064Z] Gradle Test Run :core:test > Gradle Test Executor 96 > ZkMigrationClientTest > testUpdateExisting

[jira] [Created] (KAFKA-17208) replica_scale_test.py fails for new consumer

Kirk True created KAFKA-17208: - Summary: replica_scale_test.py fails for new consumer Key: KAFKA-17208 URL: https://issues.apache.org/jira/browse/KAFKA-17208 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP-512: make Record Headers available in onAcknowledgement

Hi Rich, Thanks for resurrecting this KIP. It seems like a useful idea to me and I’d be interested in seeing the proposed public interfaces. I note that you specifically called out the ProducerInterceptor.onAcknowledgement method, as opposed to the producer Callback.onCompletion method. Thanks,

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #193

See Changes: -- [...truncated 3.46 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldUseSourceSpecificDeserializers[Eos enabled = false] PASSED org.apache.kaf

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

See