[jira] [Resolved] (KAFKA-12947) Replace EasyMock and PowerMock with Mockito for StreamsMetricsImplTest ...

[ https://issues.apache.org/jira/browse/KAFKA-12947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12947. Resolution: Duplicate this is fixed by https://github.com/apache/kafka/pull/14623 >

[jira] [Resolved] (KAFKA-16484) Support to define per broker/controller property by ClusterConfigProperty

[ https://issues.apache.org/jira/browse/KAFKA-16484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16484. Fix Version/s: 3.8.0 Resolution: Fixed > Support to define per broker/controller

Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer

Hi Mathias, > [AL1] While I see the point, I would think having a different callback for every exception might not really be elegant? I'm not sure how to assess the level of elegance of the proposal, but I can comment on the technical characteristics: 1. Having specific interfaces that codify

Re: [DISCUSS] KIP-1033: Add Kafka Streams exception handler for exceptions occuring during processing

The type safety issue is definitely not solved by having two separate callbacks. I just think it gets a bit worse by mashing them into one method. At least in the plain #handle method you can be sure that the type is ProducerRecord and in #handleSerialization the type is some POJO. And in theory

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.7 #153

See

[DISCUSS] KIP-891: Running multiple versions of Connector plugins

Hi all, I'd like to reboot the discussion on KIP-891: https://cwiki.apache.org/confluence/display/KAFKA/KIP-891%3A+Running+multiple+versions+of+Connector+plugins I've made some changes, most notably: 1. Specifying versions for all plugins in Connector configs (converters, header converters,

[jira] [Created] (KAFKA-16696) Remove the in-memory implementation of RSM and RLMM

Kamal Chandraprakash created KAFKA-16696: Summary: Remove the in-memory implementation of RSM and RLMM Key: KAFKA-16696 URL: https://issues.apache.org/jira/browse/KAFKA-16696 Project: Kafka

Re: Creating kafka wiki id

Self-service to create an account is currently not working. Please reply on https://issues.apache.org/jira/browse/INFRA-25451 to request a wiki account. I'll update the wiki page for now until the issue is resolved. -Matthias On 5/7/24 8:25 AM, 黃竣陽 wrote: Hello, I want to create a KIP, but

Re: [VOTE] KIP-1018: Introduce max remote fetch timeout config

Thanks Kamal for the KIP. +1 from me. ~Satish. On Thu, 9 May 2024 at 17:52, Christo Lolov wrote: > > Heya Kamal, > > Thanks for the KIP and the answers in the discussion! > > +1 from me :) > > Best, > Christo > > On Thu, 9 May 2024 at 11:11, Federico Valeri wrote: > > > +1 non binding > > > >

Re: [DISCUSS] KIP-1033: Add Kafka Streams exception handler for exceptions occuring during processing

Thanks Sophie! Makes it much clearer where you are coming from. About the Type unsafety: isn't this also an issue for the `handleSerialziationException` case, because the handler is used for all sink topics, and thus key/value types are not really know w/o taking the sink topic into account?

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

Christo, IMO, we can converge the implementation for both the policies and remove the remote-log-segments in async fashion. The only difference between the "delete" and "retain" policies is that, for "delete" we move the log-start-offset to match with the local-log-start-offset and then the

[jira] [Created] (KAFKA-16695) Improve expired poll interval logging by showing exceeded time

Lianet Magrans created KAFKA-16695: -- Summary: Improve expired poll interval logging by showing exceeded time Key: KAFKA-16695 URL: https://issues.apache.org/jira/browse/KAFKA-16695 Project: Kafka

Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations

After doing a brief survey of the SMTs that ship with Connect, it seems like these would also benefit: - HeaderFrom, which populates record headers with subfields of keys/values [1] - Cast, which performs type transformation on subfields of keys/values [2] - SetSchemaMetadata, which (when the

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

Heya! re: Luke 1. I am not certain I follow the question. From DISABLED you can only go to ENABLED regardless of whether your cluster is backed by Zookeeper or KRaft. Am I misunderstanding your point? 2. Apologies, this was a leftover from previous versions. I have updated the Zookeeper

[jira] [Resolved] (KAFKA-16676) Security docs missing RPCs from KIP-714 and KIP-1000

[ https://issues.apache.org/jira/browse/KAFKA-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-16676. -- Resolution: Fixed > Security docs missing RPCs from KIP-714 and KIP-1000 >

Re: [VOTE] KIP-1018: Introduce max remote fetch timeout config

Heya Kamal, Thanks for the KIP and the answers in the discussion! +1 from me :) Best, Christo On Thu, 9 May 2024 at 11:11, Federico Valeri wrote: > +1 non binding > > Thanks > > On Thu, May 9, 2024 at 12:05 PM Luke Chen wrote: > > > > Hi Kamal, > > > > Thanks for the KIP! > > +1 from me. >

Re: [VOTE] KIP-1018: Introduce max remote fetch timeout config

+1 non binding Thanks On Thu, May 9, 2024 at 12:05 PM Luke Chen wrote: > > Hi Kamal, > > Thanks for the KIP! > +1 from me. > > Thanks. > Luke > > On Mon, May 6, 2024 at 5:03 PM Kamal Chandraprakash < > kamal.chandraprak...@gmail.com> wrote: > > > Hi all, > > > > We would like to start a voting

Re: [VOTE] KIP-1018: Introduce max remote fetch timeout config

Hi Kamal, Thanks for the KIP! +1 from me. Thanks. Luke On Mon, May 6, 2024 at 5:03 PM Kamal Chandraprakash < kamal.chandraprak...@gmail.com> wrote: > Hi all, > > We would like to start a voting thread for KIP-1018: Introduce > max remote fetch timeout config for DelayedRemoteFetch requests. >

Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations

Hi Chris, > Wouldn't ValueToKey [1] be applicable as well, for example? Yes, also that one can be affected. On Wed, May 8, 2024 at 5:59 PM Chris Egerton wrote: > Wait, just one more thing--are there any other SMTs that could benefit from > this? Wouldn't ValueToKey [1] be applicable as well,

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

See