[jira] [Resolved] (KAFKA-15116) Kafka Streams processing blocked during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-15116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-15116. Resolution: Not A Problem > Kafka Streams processing blocked during

Re: [DISCUSS] KIP-975 Docker Image for Apache Kafka

Hi Vedarth, > Local Kafka startup time (without JSA): 1.592 secs > Local Kafka startup time (with JSA): 1.016 secs > Local Kafka startup memory usage (without JSA): 440MB > Local Kafka startup memory usage (with JSA): 380MB This is a significant reduction in start-up time (33%) - nice! Ismael

[jira] [Resolved] (KAFKA-12550) Introduce RESTORING state to the KafkaStreams FSM

[ https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12550. Resolution: Won't Fix Closing this out since it's usefulness is preempted

[jira] [Resolved] (KAFKA-15463) StreamsException: Accessing from an unknown node

[ https://issues.apache.org/jira/browse/KAFKA-15463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-15463. Resolution: Not A Problem > StreamsException: Accessing from an unknown

Re: [DISCUSS] KIP-990: Capability to SUSPEND Tasks on DeserializationException

1. Makes sense to me! Can you just update the name of the DeserializationHandlerResponse enum from SUSPEND to PAUSE so we're consistent with the wording? The drawback here would be that custom stateful Processors > might also be impacted, but there'd be no way to know if they're safe to > not

Re: [DISCUSS] KIP-989: RocksDB Iterator Metrics

> > If we used "iterator-duration-max", for > example, would it not be confusing that it includes Iterators that are > still open, and therefore the duration is not yet known? 1. Ah, I think I understand your concern better now -- I totally agree that a "iterator-duration-max" metric would be

Re: [VOTE] KIP-988 Streams StandbyUpdateListener

Happy to see this -- that's a +1 (binding) from me On Mon, Oct 23, 2023 at 6:33 AM Bill Bejeck wrote: > This is a great addition > > +1(binding) > > -Bill > > On Fri, Oct 20, 2023 at 2:29 PM Almog Gavra wrote: > > > +1 (non-binding) - great improvement, thanks Colt & Eduwer! > > > > On Tue,

Re: [DISCUSS] KIP-988 Streams Standby Task Update Listener

That all sounds good to me! Thanks for the KIP On Wed, Oct 25, 2023 at 3:47 PM Colt McNealy wrote: > Hi Sophie, Matthias, Bruno, and Eduwer— > > Thanks for your patience as I have been scrambling to catch up after a week > of business travel (and a few days with no time to code). I'd like to

Re: [DISCUSS] KIP-988 Streams Standby Task Update Listener

Hi Sophie, Matthias, Bruno, and Eduwer— Thanks for your patience as I have been scrambling to catch up after a week of business travel (and a few days with no time to code). I'd like to tie up some loose ends here, but in short, I don't think the KIP document itself needs any changes (our

Re: Apache Kafka 3.7.0 Release

Thanks for the response and explanations -- I think the main question for me was whether we intended to permanently increase the KF -- FF gap from the historical 1 week to 3 weeks? Maybe this was a conscious decision and I just missed the memo, hopefully someone else can chime in here. I'm all

Re: [VOTE] KIP-982: Enhance Custom KafkaPrincipalBuilder to Access SslPrincipalMapper and KerberosShortNamer

Hi all, Bumping up this vote thread We have one binding +1 vote and one non-binding +1 vote so far. Thanks, Raghu On Fri, Oct 20, 2023 at 5:04 AM Manikumar wrote: > Hi, > > Thanks for the KIP. > > +1 (binding) > > Thanks, > Manikumar > > On Fri, Oct 20, 2023 at 4:26 AM Raghu B wrote: > >>

Re: [DISCUSS] KIP-975 Docker Image for Apache Kafka

Hi Ismael! Thanks for bringing this to our attention. We did a small POC integrating CDS with Kafka server startup, and encountered positive outcomes(results are added in the KIP). Hence, we've decided to include the dynamically generated JSA file from the following workflow in the Docker image:

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

Hi Krishna, thanks for updating the KIP and all the work you are putting into that. The release process LGTM. In the other KIP I see that there will be some automation for building, testing and scanning for CVEs. Is this also true for native images? I see you are proposing to use Alpine as the

Re: [DISCUSS] KIP-992 Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery

Hi, Bill, Thank you for your reply. Yes, now, if a user executes a timestamped query against a non-timestamped store, It will throw ClassCastException. If a user uses KeyQuery to query kv-store or ts-kv-store, it always return V. If a user uses TimestampedKeyQuery to query kv-store, it will throw

Re: [DISCUSS] KIP-992 Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery

Thank you Lucas, I will fix the capitalization. When a user executes a timestamped query against a non-timestamped store, It will throw ClassCastException. Sincerely, Hanyu On Tue, Oct 24, 2023 at 1:36 AM Lucas Brutschy wrote: > Hi Hanyu, > > reading the KIP, I was wondering the same thing as

Re: [VOTE] KIP-978: Allow dynamic reloading of certificates with different DN / SANs

Hi Jakub, thanks for this KIP. +1 (non binding) Thanks Fede On Wed, Oct 25, 2023 at 4:45 PM Manikumar wrote: > > Hi, > > Thanks for the KIP. > > +1 (binding) > > > Thanks. > > On Wed, Oct 25, 2023 at 1:37 AM Jakub Scholz wrote: > > > Hi all, > > > > I would like to start a vote for the

Re: Apache Kafka 3.7.0 Release

Thanks for the thorough response, Sophie. - Added to the "Future Release Plan" > 1. Why is the KIP freeze deadline on a Saturday? It was simply added as a starting point - around 30 days from the announcement. We can move it earlier to the 15th of November, but my thinking is later is better

[jira] [Created] (KAFKA-15684) Add support to describe all subscriptions through utility

Apoorv Mittal created KAFKA-15684: - Summary: Add support to describe all subscriptions through utility Key: KAFKA-15684 URL: https://issues.apache.org/jira/browse/KAFKA-15684 Project: Kafka

[jira] [Created] (KAFKA-15683) Delete subscription from metadata when all configs are deleted

Apoorv Mittal created KAFKA-15683: - Summary: Delete subscription from metadata when all configs are deleted Key: KAFKA-15683 URL: https://issues.apache.org/jira/browse/KAFKA-15683 Project: Kafka

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

See

Re: [VOTE] KIP-978: Allow dynamic reloading of certificates with different DN / SANs

Hi, Thanks for the KIP. +1 (binding) Thanks. On Wed, Oct 25, 2023 at 1:37 AM Jakub Scholz wrote: > Hi all, > > I would like to start a vote for the KIP-978: Allow dynamic reloading of > certificates with different DN / SANs > < >

Re: [DISCUSS] KIP-969: Support range interactive queries for versioned state stores

Thanks, Matthias and Bruno. Here is a list of updates: 1. I changed the variable and method names as I did for KIP-968, as follows: - "fromTimestamp" -> fromTime - "asOfTimestamp"-> toTime - "from(instant)" -> fromTime(instant)" - asOf(instant)"->toTime(instant)

[jira] [Created] (KAFKA-15682) Ensure internal remote log metadata topic does not expire its segments before deleting user-topic segments

Kamal Chandraprakash created KAFKA-15682: Summary: Ensure internal remote log metadata topic does not expire its segments before deleting user-topic segments Key: KAFKA-15682 URL:

[jira] [Created] (KAFKA-15681) Add support of client-metrics in kafka-configs.sh

Apoorv Mittal created KAFKA-15681: - Summary: Add support of client-metrics in kafka-configs.sh Key: KAFKA-15681 URL: https://issues.apache.org/jira/browse/KAFKA-15681 Project: Kafka Issue

[jira] [Resolved] (KAFKA-15671) Flaky test RemoteIndexCacheTest.testClearCacheAndIndexFilesWhenResizeCache

[ https://issues.apache.org/jira/browse/KAFKA-15671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-15671. -- Resolution: Fixed > Flaky test

KIP-993: Allow restricting files accessed by File and Directory ConfigProviders

Hi everyone, I would like to start a discussion on KIP-933 that proposes restricting files accessed by File and Directory ConfigProviders. https://cwiki.apache.org/confluence/display/KAFKA/KIP-993%3A+Allow+restricting+files+accessed+by+File+and+Directory+ConfigProviders Regards, Tina