Re: [VOTE] KIP-1034: Dead letter queue in Kafka Streams

2025-01-03 Thread Lucas Brutschy
+1 (binding) on the updated KIP. Thanks for the updates! On Fri, Dec 20, 2024 at 2:28 AM Matthias J. Sax wrote: > > I think I did miss the train to vote originally, but I am > > +1 (binding) > > on the updated KIP. > > > -Matthias > > On 12/18/24 12:47 AM, Bruno Cadonna wrote: > > Hi, > > > > We

Re: [DISCUSS] KIP-1051 Statically configured log replication throttling

2025-01-03 Thread Divij Vaidya
Thank you for the KIP. Overall, the proposal looks good to me. I am adding some additional comments here: 1. What type of constraints do we want to add on static configuration? I am assuming we should probably define some sane lower limit so that basic replication (empty fetch requests) can still

[jira] [Created] (KAFKA-18400) Don't use YYYY when formatting dates in Java client

2025-01-03 Thread Kirk True (Jira)
Kirk True created KAFKA-18400: - Summary: Don't use when formatting dates in Java client Key: KAFKA-18400 URL: https://issues.apache.org/jira/browse/KAFKA-18400 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-17615) Remove KafkaServer references in tests

2025-01-03 Thread TaiJuWu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TaiJuWu resolved KAFKA-17615. - Assignee: Mickael Maison (was: Colin McCabe) Resolution: Fixed > Remove KafkaServer references in

Re: [DISCUSS] KIP-955: Add stream-table join on foreign key

2025-01-03 Thread Matthias J. Sax
I am moving this KIP to "discarded" state, as there was no further activity. On 3/8/24 7:02 PM, Matthias J. Sax wrote: Igor, I did drop the ball on this discussion. Sorry about this. Too many things are happening at the same time. Also I do not think that emitting multiple records from th

[jira] [Resolved] (KAFKA-4437) Incremental Batch Processing for Kafka Streams

2025-01-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4437. Resolution: Abandoned > Incremental Batch Processing for Kafka Streams > --

Re: [DISCUSS] KIP-634: Complementary support for headers in Kafka Streams DSL

2025-01-03 Thread Matthias J. Sax
Moving this KIP into "discarded" state. While header support is still limited, we should rather move a `Record` base API following the new PAPI, and thus this KIP does not make any sense any longer from my POV. On 3/21/22 1:13 PM, Jorge Esteban Quilcate Otoya wrote: Hi all, With the acceptanc

[jira] [Resolved] (KAFKA-15299) Support left stream-table join on foreign key

2025-01-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15299. - Resolution: Incomplete Closing this ticket as "incomplete". The KIP discussion did not

[jira] [Resolved] (KAFKA-6953) [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure)

2025-01-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6953. Resolution: Abandoned > [Streams] Schedulable KTable as Graph source (for minimizing aggreg

Re: KIP-675: Convert KTable to a KStream using the previous value

2025-01-03 Thread Matthias J. Sax
Moving this very old KIP into "discarded" state. On 10/9/20 4:03 AM, Javier Freire Riobo wrote: I see. It's great hidden functionality and all you have to do is define a good API and expose it. I think the easiest thing would be to expose a first operator, and then add more operators if they are

[jira] [Resolved] (KAFKA-10578) Convert KTable to a KStream using the previous value

2025-01-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10578. - Resolution: Abandoned Closing this ticket. The KIP discussion did not lead to a resoluti

Re: [DISCUSS] KIP-1114 Introducing Chunk in Partition

2025-01-03 Thread De Gao
Thanks David for the detailed review. Appreciated. I will try to answer your most important question: what is the problem I am trying to solve here. This KIP will surely resolve some technical problems. But that's not the original purpose. I am trying to resolve a problem in Kafka's design. T

Re: [DISCUSS] KIP-1114 Introducing Chunk in Partition

2025-01-03 Thread De Gao
Thanks for the review. This is an interesting idea. Indeed this will significantly reduce the data need to be copied. But this may need to take the TTL time to get the new replica join the ISRs. Also we need to consider how to handle the partitions that will only do purge by data size. On 2 Jan

[jira] [Created] (KAFKA-18399) Remove ZooKeeper from KafkaApis

2025-01-03 Thread Mickael Maison (Jira)
Mickael Maison created KAFKA-18399: -- Summary: Remove ZooKeeper from KafkaApis Key: KAFKA-18399 URL: https://issues.apache.org/jira/browse/KAFKA-18399 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18398) Log a warning if actual topic configs are inconsistent with the required topic configs

2025-01-03 Thread Lucas Brutschy (Jira)
Lucas Brutschy created KAFKA-18398: -- Summary: Log a warning if actual topic configs are inconsistent with the required topic configs Key: KAFKA-18398 URL: https://issues.apache.org/jira/browse/KAFKA-18398

Re: [DISCUSS]KIP-1107: Adding record-level acks for producers

2025-01-03 Thread Divij Vaidya
Hey TaiJu I read the latest version of the KIP. I understand the problem you are trying to solve here. But the solution needs more changes than you proposed and hence, is not straightforward. As an example, we haven't answered the question about protocol for ProduceRequest raised above. A `Produc

[jira] [Resolved] (KAFKA-17946) Flaky test DeafultStateUpdaterTest::shouldResumeStandbyTask due to concurrency issue

2025-01-03 Thread Lucas Brutschy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-17946. Resolution: Fixed > Flaky test DeafultStateUpdaterTest::shouldResumeStandbyTask due to >

Re: [DISCUSS] KIP-1095: Kafka Canary Isolation

2025-01-03 Thread Divij Vaidya
Hello Chen Thank you for the KIP. I have a few questions/thoughts: 1. Why can’t we achieve the objective without making any change at all? For example, you can designate a few brokers as your “canary brokers” where your custom "canary partitions" are situated. During rolling deployment you can c

[jira] [Resolved] (KAFKA-18256) Performance Testing (Optional but Recommended)

2025-01-03 Thread Swikar Patel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swikar Patel resolved KAFKA-18256. -- Resolution: Done > Performance Testing (Optional but Recommended) > --

[jira] [Resolved] (KAFKA-18257) Update Documentation

2025-01-03 Thread Swikar Patel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swikar Patel resolved KAFKA-18257. -- Resolution: Done > Update Documentation > > > Key: KAFKA-

[jira] [Resolved] (KAFKA-18258) Code Review

2025-01-03 Thread Swikar Patel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swikar Patel resolved KAFKA-18258. -- Resolution: Done > Code Review > --- > > Key: KAFKA-18258 >