Re: [DISCUSS] KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores

2023-11-02 Thread Bruno Cadonna
(as private method) that can be called from `query()` method, but adding it to the interface seems to defeat the purpose of IQv2. Note, for existing IQv2 queries types that go against others stores, the public methods already existed when IQv2 was introduces, and thus the implementation of thes

Re: [VOTE] KIP-998: Give ProducerConfig(props, doLog) constructor protected access

2023-11-03 Thread Bruno Cadonna
Thanks for the KIP! +1 (binding) Best, Bruno On 11/3/23 7:55 AM, Chris Egerton wrote: +1 (binding) FWIW, I agree that this change should require a KIP. Gating upgrades of visibility from private or package-private to protected may be cumbersome, but it comes with the expectation that

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

2023-11-03 Thread Bruno Cadonna
I assume, results are returned by timestamp for each key. The KIP should be explicit about it. To be very explicit, should we rename the methods to specify the key bound? - withRange -> withKeyRange - withLowerBound -> withLowerKeyBound - withUpperBound -> withUpperKeyBou

Re: [ANNOUNCE] New Kafka PMC Member: Satish Duggana

2023-10-30 Thread Bruno Cadonna
Congrats, Satish! Bruno On 10/29/23 2:42 PM, John Roesler wrote: Congratulations, Satish! -John On Sun, Oct 29, 2023, at 08:09, Randall Hauch wrote: Congratulations, Satish! On Sun, Oct 29, 2023 at 1:47 AM Tom Bentley wrote: Congratulations! On Sun, 29 Oct 2023 at 5:41 PM, Guozhang Wang

Re: [VOTE] KIP-988 Streams StandbyUpdateListener

2023-10-31 Thread Bruno Cadonna
Hi Colt and Eduwer, Thanks for the KIP! +1 (binding) Best, Bruno On 10/26/23 7:17 PM, Matthias J. Sax wrote: +1 (binding) On 10/25/23 4:06 PM, Sophie Blee-Goldman wrote: 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

[ANNOUNCE] New committer: Yash Mayya

2023-09-21 Thread Bruno Cadonna
Hi all, The PMC of Apache Kafka is pleased to announce a new Kafka committer Yash Mayya. Yash's major contributions are around Connect. Yash authored the following KIPs: KIP-793: Allow sink connectors to be used with topic-mutating SMTs KIP-882: Kafka Connect REST API configuration

[ANNOUNCE] New committer: Lucas Brutschy

2023-09-21 Thread Bruno Cadonna
Hi all, The PMC of Apache Kafka is pleased to announce a new Kafka committer Lucas Brutschy. Lucas' major contributions are around Kafka Streams. Lucas' significantly contributed to the state updater (https://issues.apache.org/jira/browse/KAFKA-10199) and he drives the implementation of

Re: [DISCUSS] KIP-985 Add reverseRange and reverseAll query over kv-store in IQv2

2023-10-04 Thread Bruno Cadonna
Hi Hanyu, I agree with what others said about having a `withDescendingOrder()` method and about to document how the results are ordered. I would not add a reverse flag and adding a parameter to each method in RangeQuery. This makes the API less fluent and harder to maintain since the flag

Re: [DISCUSS] KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores

2023-10-04 Thread Bruno Cadonna
some better name?) to allow specifying both bounds at once? The existing `RangeQuery` does the same for specifying the key-range, so might be good to add for time-range too? -Matthias On 9/6/23 5:01 AM, Bruno Cadonna wrote: In my last e-mail I missed to finish a sentence. "I think from a KIP

Re: [DISCUSS] KIP-892: Transactional Semantics for StateStores

2023-09-19 Thread Bruno Cadonna
on the API for now, but I think it's important to consider how to implement the desired API, in case we come up with an API that cannot be implemented efficiently, or even at all! Thoughts? -- Nick On Wed, 13 Sept 2023 at 13:03, Bruno Cadonna wrote: Hi Nick, 6. Of course, you are right

Re: [ANNOUNCE] New Kafka PMC Member: Justine Olshan

2023-09-25 Thread Bruno Cadonna
Congrats, Justine! Well deserved! Best, Bruno On 9/25/23 5:28 AM, ziming deng wrote: Congratulations Justine! On Sep 25, 2023, at 00:01, Viktor Somogyi-Vass wrote: Congrats Justine! On Sun, Sep 24, 2023, 17:45 Kirk True wrote: Congratulations Justine! Thanks for all your great work!

Re: KAFKA-15571 Review

2023-10-10 Thread Bruno Cadonna
Hi Levani, I think you found a bug and you are looking at the right place! I commented on the PR. Best, Bruno On 10/10/23 3:02 PM, Levani Kokhreidze wrote: Hello, We’ve been looking at a https://issues.apache.org/jira/browse/KAFKA-10575 but seems implementation has a bug and user defined

Re: [DISCUSS] KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores

2023-10-05 Thread Bruno Cadonna
o omit `get`. -Matthias On 10/4/23 2:36 AM, Bruno Cadonna wrote: Hi, Regarding tombstones: As far as I understand, we need to add either a validTo field to VersionedRecord or we need to return tombstones, otherwise the result is not complete, because users could never know a record was

Re: [DISCUSS] KIP-892: Transactional Semantics for StateStores

2023-10-19 Thread Bruno Cadonna
Fri, Oct 13, 2023 at 8:48 AM Nick Telford < nick.telf...@gmail.com> wrote: Hi Bruno, 4. I'll hold off on making that change until we have a consensus as to what configuration to use to control all of this, as it'll be affected by the decision on EOS isolation levels. 5. Done. I'v

Re: [VOTE] KIP-960: Support single-key_single-timestamp interactive queries (IQv2) for versioned state stores

2023-10-11 Thread Bruno Cadonna
Thanks for the KIP, Alieh! +1 (binding) Best, Bruno On 10/10/23 1:14 AM, Matthias J. Sax wrote: One more nit: as discussed on the related KIP-698 thread, we should not use `get` as prefix for the getters. So it should be `K key()` and `Optional asOfTimestamp()`. Otherwise the KIP LGTM.

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

2023-10-20 Thread Bruno Cadonna
this option will force us to invoke StandbyUpdateLister once this interval is reached. On Mon, Oct 16, 2023 at 8:52 AM Bruno Cadonna wrote: Thanks for the KIP, Colt and Eduwer, Are you sure there is also not a significant performance impact for passing into the callback `currentEndOffset`? I am asking bec

Re: [DISCUSS] KIP-892: Transactional Semantics for StateStores

2023-10-13 Thread Bruno Cadonna
ED when processing.mode is anything other than at-least-once. Do you think this would be acceptable? In a later KIP, we can add support for query-time isolation levels and solve this particular problem there, which would relax this restriction. Regards, Nick On Tue, 19 Sept 2023 at 09:30, Bruno Cad

Re: Apache Kafka 3.7.0 Release

2023-10-10 Thread Bruno Cadonna
Thanks Stan! +1 Best, Bruno On 10/10/23 7:24 AM, Luke Chen wrote: Thanks Stanislav! On Tue, Oct 10, 2023 at 3:05 AM Josep Prat wrote: Thanks Stanislav! ——— Josep Prat Aiven Deutschland GmbH Alexanderufer 3-7, 10117 Berlin Amtsgericht Charlottenburg, HRB 209739 B Geschäftsführer:

Re: [DISCUSS] KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores

2023-10-11 Thread Bruno Cadonna
tthias J. Sax wrote: Bruno and I had some background conversation about the `get` prefix question including a few other committers. The official policy was never changed, and we should not add the `get`-prefix. It's a slip on our side in previous KIPs to add the `get`-prefix and we should actually

Re: [kafka-clients] Re: [VOTE] 3.2.0 RC0

2022-04-26 Thread Bruno Cadonna
fixes an issue introduced in 3.2.0 where in some of the error cases, the producer interceptor is called twice for the same record. Thanks, Jun On Tue, Apr 26, 2022 at 6:34 AM Bruno Cadonna <mailto:cado...@apache.org>> wrote: Hi all, This is a gently reminder to vot

Re: [VOTE] 3.2.0 RC0

2022-04-26 Thread Bruno Cadonna
://jenkins.confluent.io/job/system-test-kafka/job/3.2/24/ Thank you to Michal for voting on the release candidate. Best, Bruno On 15.04.22 21:05, Bruno Cadonna wrote: Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 3.2.0. * log4j 1.x is replaced

Re: [DISCUSS] KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores

2023-11-09 Thread Bruno Cadonna
arity and even review that ;-) Cheers, Alieh On Thu, Nov 2, 2023 at 7:13 PM Bruno Cadonna wrote: Hi Alieh, First of all, I like the examples. Is validTo in VersionedRecord exclusive or inclusive? In the javadocs you write: "@param validTothe latest timestamp that value is valid" I

Re: [kafka-clients] Re: [VOTE] 3.2.0 RC1

2022-05-16 Thread Bruno Cadonna
On Thu, May 12, 2022 at 12:03 PM Bruno Cadonna wrote: Hi all, Please review the blog post for the Apache Kafka 3.2.0 release: https://blogs.apache.org/preview/kafka/?previewEntry=what-s-new-in-apache8 I will accept comments until Monday, May 16th EOD PT. Best, Bruno On 06.05.22 14:52, 'Da

Re: [ANNOUNCE] Apache Kafka 3.1.1

2022-05-16 Thread Bruno Cadonna
Thanks Tom! On 16.05.22 10:25, David Jacot wrote: Thanks for driving this release, Tom! On Fri, May 13, 2022 at 12:50 PM Tom Bentley wrote: The Apache Kafka community is pleased to announce the release for Apache Kafka 3.1.1 Apache Kafka 3.1.1 is a bugfix release and 30 issues have been

Re: [kafka-clients] Re: [VOTE] 3.2.0 RC1

2022-05-17 Thread Bruno Cadonna
Hi Bruno, One clarification, the documentation that was updated is not shipped with the release - it's only on the website. As you said, the website can be updated at any time. Ismael On Mon, May 16, 2022 at 4:16 AM Bruno Cadonna wrote: Hi Divij, The documentation that is shipped with Apache K

[ANNOUNCE] Apache Kafka 3.2.0

2022-05-17 Thread Bruno Cadonna
Khamphousone, bozhao12, Bruno Cadonna, Chang, Chia-Ping Tsai, Chris Egerton, Colin P. Mccabe, Colin Patrick McCabe, Cong Ding, David Arthur, David Jacot, David Mao, defhacks, dengziming, Ed B, Edwin, florin-akermann, GauthamM-official, GuoPhilipse, Guozhang Wang, Hao Li, Haoze Wu, Idan Kamara

Re: [kafka-clients] Re: [VOTE] 3.2.0 RC1

2022-05-16 Thread Bruno Cadonna
: Perhaps, we want to merge in https://github.com/apache/kafka/pull/12164 before this release? Divij Vaidya On Mon, May 16, 2022 at 11:30 AM Bruno Cadonna wrote: Mickael, Thanks a lot! Totally, missed that! Best, Bruno On 16.05.22 10:13, Mickael Maison wrote: Hi Bruno, The blog post looks

Re: [DISCUSS] KIP-832 Allow creating a producer/consumer using a producer/consumer config

2022-05-12 Thread Bruno Cadonna
te another KIP explaining the builder approach or do you prefer to do it? Kr, F. Le mer. 11 mai 2022 à 09:46, Bruno Cadonna a écrit : Hi Francois and Chris, I find the idea of the builder interesting. I think we should go ahead with the current KIP as it is to allow Francois to fix his

Re: [kafka-clients] Re: [VOTE] 3.2.0 RC1

2022-05-12 Thread Bruno Cadonna
Jakub Scholz wrote: +1 (non-binding). I used the Scala 2.13 binaries and the staged Maven artifacts and ran various tests with them. Thanks for doing the release. Jakub On Tue, May 3, 2022 at 4:07 PM Bruno Cadonna wrote: Hello Kafka users, developers and client-developers, This is the second

Re: [VOTE] KIP-843: Adding metricOrElseCreate method to Metrics

2022-05-24 Thread Bruno Cadonna
Hi Sagar, +1 (binding) Thanks, Bruno On 24.05.22 18:22, Sagar wrote: Hi John, No worries. addMetric throws an exception which needs to be handled. This new method removes that need similar to what you have done for the sensor method. Thanks! Sagar. On Tue, May 24, 2022 at 8:19 PM Guozhang

Re: [DISCUSS] KIP-843 Adding metricOrElseCreate method to Metrics.

2022-05-24 Thread Bruno Cadonna
to remove them during PR review: https://github.com/apache/kafka/pull/12121#discussion_r875156714 3) I updated the KIP with the function name you suggested. Thanks! Sagar. On Tue, May 24, 2022 at 9:34 PM Bruno Cadonna wrote: Sagar, Thanks for the KIP! 1. Could you please add the class to which you

Re: [VOTE] KIP-846: Processor-level Streams metrics for records/bytes Producedd

2022-05-30 Thread Bruno Cadonna
+1 (binding) Thanks! Bruno On 30.05.22 09:36, Sophie Blee-Goldman wrote: Hey all, I'd like to kick off the voting thread for the KIP I proposed to add processor-level "bytes/records produced" metrics to Kafka Streams. Thanks! KIP-846: Task-level Streams metrics for bytes/records Produced

Re: [DISCUSS] KIP-846: Task-level Streams metrics for bytes/records Produced

2022-05-30 Thread Bruno Cadonna
Thanks for the KIP, Sophie! I am also in favor of this KIP! I have one minor question: Why does the title of the KIP talk about task-level metrics, but the specified metrics are on processor-level? For the rest, I am +1. Best, Bruno On 29.05.22 00:20, John Roesler wrote: Thanks for the

Re: [VOTE] KIP-843: Adding metricOrElseCreate method to Metrics

2022-05-30 Thread Bruno Cadonna
Hi Sagar, Hi Ismael, what about getOrCreateMetric()? Best, Bruno On 28.05.22 18:56, Sagar wrote: Hi Ismael, Actually Bruno suggested renaming it to getMetricOrElseCreate and we decided to go ahead with that one. These were the only names that we considered for the KIP. Thanks! Sagar. On

Re: [VOTE] KIP-843: Adding metricOrElseCreate method to Metrics

2022-05-30 Thread Bruno Cadonna
or creates a sensor. How about using `metric` to follow the same naming convention? Best, David On Mon, May 30, 2022 at 9:18 AM Bruno Cadonna wrote: Hi Sagar, Hi Ismael, what about getOrCreateMetric()? Best, Bruno On 28.05.22 18:56, Sagar wrote: Hi Ismael, Actually Bruno suggested

Re: [DISCUSS] KIP-844: Transactional State Stores

2022-05-30 Thread Bruno Cadonna
Thanks for the PR, Alex! I am also glad to see this coming. 1. Configuration I would also prefer to restrict the configuration of transactional on the state sore. Ideally, calling method transactional() on the state store would be enough. An option on the store builder would make it

Re: Permission request to contribute

2022-05-18 Thread Bruno Cadonna
Hi Alexandre, you should be all set now! Thank you for your interest in Apache Kafka! Best, Bruno On 18.05.22 09:40, Alexandre Garnier wrote: Hi there! I'd like to request permission to contribute to Kafka. Wiki ID: zigarn Jira ID: zigarn Thanks,

Re: [ANNOUNCE] Apache Kafka 3.2.0

2022-05-20 Thread Bruno Cadonna
hould we fix that typo? Thanks! -James On May 17, 2022, at 9:01 AM, Bruno Cadonna wrote: The Apache Kafka community is pleased to announce the release for Apache Kafka 3.2.0 * log4j 1.x is replaced with reload4j (KAFKA-9366) * StandardAuthorizer for KRaft (KIP-801) * Send a hint to the part

Re: [VOTE] KIP-851: : Add requireStable flag into ListConsumerGroupOffsetsOptions

2022-07-04 Thread Bruno Cadonna
there is real value in doing it. We don't necessarily have to add all the options to it but we could if it is proven to be useful. Anyway, I would leave it for a future KIP. +1 (binding) Best, David On Fri, Jul 1, 2022 at 9:47 AM Bruno Cadonna wrote: Hi Guozhang, thank you for the KIP! I do not

Re: [VOTE] KIP-851: : Add requireStable flag into ListConsumerGroupOffsetsOptions

2022-07-01 Thread Bruno Cadonna
Hi Guozhang, thank you for the KIP! I do not have strong feelings about the naming of the getter, but I tend to agree with Luke. Regarding, the adaptation of the kafka-consumer-group.sh script, I am fine if we leave that for a future KIP. +1 (binding) Best, Bruno On 01.07.22 06:05, Luke

Re: [External] Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #995

2022-06-13 Thread Bruno Cadonna
Hi Nicola, The ETA for Kafka 4.0 in which log4j will be updated to version 2 is going to be released in the second half of 2023. In the meanwhile we replaced log4j with reload4j in release 3.2.0. Reload4j closes the known vulnerabilities of log4j1. Out of curiosity, why do you reply to a

Re: [DISCUSS] KIP-843 Adding metricOrElseCreate method to Metrics.

2022-05-24 Thread Bruno Cadonna
Sagar, Thanks for the KIP! 1. Could you please add the class to which you want to add the method in section "Public Interfaces"? Ideally, in the header of the code part that contains "prefixScan" currently. 2. Do you also plan to add overloads for metricOrElseCreate() similar as for

Re: Wiki permissions request

2022-07-20 Thread Bruno Cadonna
Hi Michael, I found that in Jira you are already part of the contributors. I gave you contributor permissions in the wiki. Thank you for your interest in Apache Kafka! Best, Bruno On 20.07.22 06:20, Michael Negodaev wrote: Hi, I'd like to be added to the contributors list, so that I can

Re: [ANNOUNCE] New Committer: Chris Egerton

2022-07-26 Thread Bruno Cadonna
Congratulations Chris! Well deserved! Best, Bruno On 26.07.22 05:24, Kumud Kumar Srivatsava Tirupati wrote: Congratulations Chris! On Tue, 26 Jul, 2022, 7:11 AM deng ziming, wrote: Congratulations Chris ! -- Ziming On Jul 26, 2022, at 5:01 AM, Matthias J. Sax wrote: Congrats! Well

Re: [DISCUSS] KIP-844: Transactional State Stores

2022-07-29 Thread Bruno Cadonna
s for the KIP proposal Alex. 1. Configuration default You mention applications using streams DSL with built-in rocksDB state store will get transactional state stores by default when EOS is enabled, but the default implementation for apps using PAPI will fallback to non-transactional beha

Re: [kafka-clients] Re: [VOTE] 3.2.0 RC0

2022-05-02 Thread Bruno Cadonna
for the reply. Your understanding is correct. This is a regression introduced only in the 3.2 branch. Sorry for the late notice. Jun On Tue, Apr 26, 2022 at 10:04 AM Bruno Cadonna wrote: Hi Jun, Thank you for your message! Now I see how this issue was introduced in 3.2.0. The fix for the bug described

Re: [DISCUSS] KIP-832 Allow creating a producer/consumer using a producer/consumer config

2022-05-06 Thread Bruno Cadonna
gt;> add/change the constructors that take only the properties? Best, Bruno On 05.05.22 23:15, François Rosière wrote: Hello Bruno, The KIP as been updated. Feel free to give more feedbacks and I will complete accordingly. Kr, F. Le jeu. 5 mai 2022 à 22:22, Bruno Cadonna a écrit : Hi Francois,

Re: [kafka-clients] Re: [VOTE] 3.2.0 RC0

2022-04-28 Thread Bruno Cadonna
On Tue, Apr 26, 2022 at 10:04 AM Bruno Cadonna wrote: Hi Jun, Thank you for your message! Now I see how this issue was introduced in 3.2.0. The fix for the bug described in KAFKA-12841 introduced it, right? I initially understood that the PR you want to include is the fix for the bug

[VOTE] 3.2.0 RC1

2022-05-03 Thread Bruno Cadonna
Hello Kafka users, developers and client-developers, This is the second candidate for release of Apache Kafka 3.2.0. * log4j 1.x is replaced with reload4j (KAFKA-9366) * StandardAuthorizer for KRaft (KIP-801) * Send a hint to the partition leader to recover the partition (KIP-704) * Top-level

Re: [VOTE] 3.2.0 RC1

2022-05-04 Thread Bruno Cadonna
Hello Kafka users, developers and client-developers, I've got a green build with unit/integration tests: https://ci-builds.apache.org/job/Kafka/job/kafka/job/3.2/45/ Best, Bruno On 03.05.22 16:07, Bruno Cadonna wrote: Hello Kafka users, developers and client-developers, This is the second

Re: [VOTE] KIP-834: Pause / Resume KafkaStreams Topologies

2022-05-10 Thread Bruno Cadonna
Thanks Jim, +1 (binding) Best, Bruno On 10.05.22 21:19, John Roesler wrote: Thanks Jim, I’m +1 (binding) -John On Tue, May 10, 2022, at 14:05, Jim Hughes wrote: Hi all, I'm asking for a vote on KIP-834: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211882832 Thanks in

Re: [DISCUSS] Apache Kafka 3.3.0 Release

2022-05-11 Thread Bruno Cadonna
Thanks José! +1 Best, Bruno On 11.05.22 04:38, John Roesler wrote: +1 from me! Thanks for volunteering, José. -John On Tue, May 10, 2022, at 17:53, José Armando García Sancio wrote: Hi all, I would like to volunteer for the release of Apache Kafka 3.3.0. If people agree, I'll start working

Re: [DISCUSS] KIP-832 Allow creating a producer/consumer using a producer/consumer config

2022-05-11 Thread Bruno Cadonna
instances); return this; } public KafkaProducer build() { ... } } Thoughts? [1] - https://kafka.apache.org/31/javadoc/org/apache/kafka/common/config/AbstractConfig.html#getConfiguredInstances(java.lang.String,java.lang.Class,java.util.Map) Cheers, Chris On Mon, May 9, 2022 at 4:55 PM Bruno Ca

Re: [DISCUSS] KIP-832 Allow creating a producer/consumer using a producer/consumer config

2022-05-09 Thread Bruno Cadonna
e it respond to the question. Kr, F. Le ven. 6 mai 2022 à 11:59, Bruno Cadonna a écrit : Hi Francois, Thank you for updating the KIP! Now the motivation of the KIP is much clearer. I would still be interested in: >> 2. Why do you only want to change/add the constructors that take the >

[RESULTS] [VOTE] Release Kafka version 3.2.0

2022-05-09 Thread Bruno Cadonna
This vote passes with 5 +1 votes (3 bindings) and no 0 or -1 votes. +1 votes PMC Members: * Bill Bejeck * Mickael Maison * David Jacot Committers: * Luke Chen Community: * Jakub Scholz 0 votes * No votes -1 votes * No votes Vote thread:

Re: [DISCUSS] KIP-832 Allow creating a producer/consumer using a producer/consumer config

2022-05-09 Thread Bruno Cadonna
lso remove section "Public Interfaces" since it does not contain much information. Best, Bruno On 09.05.22 17:45, Bruno Cadonna wrote: Hi Francois, You can open a PR and people can review it, but it must not be merged until the KIP is approved. Best, Bruno On 09.05.22 16:07, Fr

Re: Contributor access

2022-05-10 Thread Bruno Cadonna
Hi Jakub, I added you to the contributors in Jira. You are now able to assign tickets to yourself. Thank you for your interest in Apache Kafka! Best, Bruno On 10.05.22 00:22, Jakub Miroś wrote: Hello, I want to offer a help as a new contributor. Please add me to the Jira, my ID is

Re: [DISCUSS] KIP-834: Pause / Resume KafkaStreams Topologies

2022-05-10 Thread Bruno Cadonna
Hi Jim, Thanks for the KIP! I am fine with the KIP in general. However, I am with Sophie and John to also pause the standbys for the reasons they brought up. Is there a specific reason you want to keep standbys going? It feels like premature optimization to me. We can still add keeping

Re: [VOTE] KIP-832 Allow creating a producer/consumer using a producer/consumer

2022-05-10 Thread Bruno Cadonna
Hi Francois, Thanks for the KIP whose link is: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211882578 +1 (binding) Best, Bruno On 09.05.22 23:23, François Rosière wrote:

Re: [DISCUSS] KIP-832 Allow creating a producer/consumer using a producer/consumer config

2022-05-05 Thread Bruno Cadonna
Hi Francois, Thanks for the KIP! Here my first feedback: 1. Could you please extend the motivation section, so that it is clear for a non-Spring dev why the change is needed? Usually, a motivation section benefits a lot from an actual example. Extending the motivation section would also make

Re: [VOTE] KIP-837 Allow MultiCasting a Result Record.

2022-08-29 Thread Bruno Cadonna
Hi Sagar, I do not see an issue with using an empty list together with an empty Optional. A non-empty Optional that contains an empty list would just say that there is no partition to which the record should be sent. If there is no partition, the record is dropped. An empty Optional might

Re: [VOTE] KIP-837 Allow MultiCasting a Result Record.

2022-08-30 Thread Bruno Cadonna
On Mon, Aug 29, 2022 at 7:32 AM Bruno Cadonna wrote: Hi Sagar, I do not see an issue with using an empty list together with an empty Optional. A non-empty Optional that contains an empty list would just say that there is no partition to which the record should be sent. If there is no partition

Re: [VOTE] KIP-844: Transactional State Stores

2022-09-01 Thread Bruno Cadonna
Thanks for the KIP! +1 (binding) Best, Bruno On 01.09.22 15:26, Colt McNealy wrote: +1 Hi Alex, Thank you for your work on the KIP. I'm not a committer so my vote is non-binding but I strongly support this improvement. Thank you, Colt McNealy *Founder, LittleHorse.io* On Thu, Sep 1, 2022

Re: [VOTE] KIP-837 Allow MultiCasting a Result Record.

2022-09-07 Thread Bruno Cadonna
30, 2022 at 8:55 AM Bruno Cadonna wrote: Hi Sagar, Thank you for the updates! I do not intend to prolong this vote thread more than needed, but I still have some points. The deprecated partition method can return null if the default partitioning logic of the producer should be used. With the

Re: [VOTE] KIP-837 Allow MultiCasting a Result Record.

2022-08-30 Thread Bruno Cadonna
if it looks fine now. Thanks! Sagar. On Tue, Aug 30, 2022 at 3:00 PM Bruno Cadonna wrote: Hi, I am favour of discarding the sugar for broadcasting and leave the broadcasting to the implementation as Chris suggests. I think that is the cleanest option. Best, Bruno On 29.08.22 19:50, Chris Egerton

Re: [VOTE] KIP-837 Allow MultiCasting a Result Record.

2022-08-24 Thread Bruno Cadonna
Hi Sagar, Thank you for the KIP and sorry for being late to the party! 1. The java docs for partitions() say: "Note that returning a single valued list with value -1 is a shorthand for broadcasting the record to all the partitions of the topic." I guess that is not true anymore since the

Re: Commercial support

2022-09-28 Thread Bruno Cadonna
Hi Francois, I am not aware of such a page on the Apache Kafka website. There are a variety of companies that sell Kafka as a self-hosted platform or as a Cloud-hosted service. Those companies include Confluent (disclaimer: I work for them), Red Hat, AWS, Aiven, Instaclustr, Cloudera, and

Re: Requesting Access to contribute to the wiki.

2022-10-17 Thread Bruno Cadonna
Hi Snehashis, You should be all set up, now! Thank you for your interest in Apache Kafka! Best, Bruno On 17.10.22 09:22, Snehashis wrote: Hi team, I would like to request contributor access to the project, to be able to write KIPs and assign tickets to me. Wiki ID: snehashisp JIRA ID:

Re: [DISCUSS] KIP-869: Improve Streams State Restoration Visibility

2022-09-19 Thread Bruno Cadonna
Hi Guozhang, Thanks for the KIP! I think this KIP is a really nice addition to better understand what is going on in a Kafka Streams application. 1. The metric names "paused-active-tasks" and "paused-standby-tasks" might be a bit confusing since at least active tasks can be paused also

Re: [VOTE] KIP-837 Allow MultiCasting a Result Record.

2022-09-12 Thread Bruno Cadonna
Hi Sagar, Thanks for the update and the PR! +1 (binding) Best, Bruno On 10.09.22 18:57, Sagar wrote: Hi Bruno, Thanks, I think these changes make sense to me. I have updated the KIP accordingly. Thanks! Sagar. On Wed, Sep 7, 2022 at 2:16 PM Bruno Cadonna wrote: Hi Sagar, I would

Re: [DISCUSS] KIP-869: Improve Streams State Restoration Visibility

2022-09-22 Thread Bruno Cadonna
"restore" (except the "restoring-active-tasks") to "state-update", a.k.a "state-update-ratio", "state-update-records-total", "updating-standby-tasks" etc. 3. Regarding the function name: yeah I think that's a valid concern, I can ch

Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins

2022-09-16 Thread Bruno Cadonna
Hi Vicky, Thanks for the KIP! I think the KIP looks good! You described how the self-join is optimized when the names of the state stores are automatically generated by Streams. I think for completeness you should also mention what happens when users explicitly name the state stores of the

Re: [DISCUSS] Apache Kafka 3.4.0 release

2022-10-10 Thread Bruno Cadonna
+1 Thanks Sophie! Best, Bruno On 06.10.22 00:01, Sophie Blee-Goldman wrote: Hey all, I'd like to volunteer as release manager for the next feature release, which will be Apache Kafka 3.4.0. If that sounds good to everyone I'll update this thread with the release plan in the coming week.

Re: [ANNOUNCE] New committer: Deng Ziming

2022-10-10 Thread Bruno Cadonna
Congrats Ziming! Best, Bruno On 10.10.22 18:30, Jason Gustafson wrote: Hi All The PMC for Apache Kafka has invited Deng Ziming to become a committer, and we are excited to announce that he has accepted! Ziming has been contributing to Kafka for about three years. He has authored more than

Re: Request permissions to contribute to kafka

2022-10-10 Thread Bruno Cadonna
Hi Junyang Liu, I added you to the contributors group in the Apache Kafka Jira. Thank you for your interest in Apache Kafka. Best, Bruno On 10.10.22 14:56, Junyang Liu wrote: Jira ID: aglicacha Thank you, — Junyang Liu

Re: [DISCUSS] KIP-844: Transactional State Stores

2022-08-10 Thread Bruno Cadonna
/processor/internals/ProcessorStateManager.java#L250-L265 12. https://github.com/apache/kafka/blob/549e54be95a8e1bae1e97df2c21d48c042ff356e/streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractTransactionalStore.java#L84-L88 Best, Alex On Fri, Jul 29, 2022 at 3:42 PM Bruno Cado

Re: [ANNOUNCE] New Kafka PMC Member: A. Sophie Blee-Goldman

2022-08-09 Thread Bruno Cadonna
Congrats, Sophie! Bruno On 03.08.22 21:26, Jeremy Custenborder wrote: Congrats Sophie! On Wed, Aug 3, 2022 at 9:25 AM David Arthur wrote: Well done! Congrats! -David On Wed, Aug 3, 2022 at 9:48 AM Sagar wrote: Congratulations Sophie ! On Wed, 3 Aug 2022 at 6:37 PM, José Armando

Re: [DISCUSS] KIP-878: Autoscaling for Statically Partitioned Streams

2022-10-31 Thread Bruno Cadonna
Hi Sophie, Thank you for the KIP! 1. I do not understand how autoscaling should work with a Streams topology with a stateful sub-topology that reads from the input topics. The simplest example is a topology that consists of only one stateful sub-topology. As far as I understand the upstream

Re: [ANNOUNCE] New committer: Edoardo Comar

2023-01-10 Thread Bruno Cadonna
Congrats! Best, Bruno On 10.01.23 11:00, Edoardo Comar wrote: Many thanks everyone ! On Mon, 9 Jan 2023 at 19:40, Rajini Sivaram wrote: Congratulations, Edo! Regards, Rajini On Mon, Jan 9, 2023 at 10:16 AM Tom Bentley wrote: Congratulations! On Sun, 8 Jan 2023 at 01:14, Satish

Re: [ANNOUNCE] New committer: Satish Duggana

2023-01-10 Thread Bruno Cadonna
Congrats! Best, Bruno On 24.12.22 12:44, Manikumar wrote: Congrats, Satish! Well deserved. On Sat, Dec 24, 2022, 5:10 PM Tom Bentley wrote: Congratulations! On Sat, 24 Dec 2022 at 05:05, Luke Chen wrote: Congratulations, Satish! On Sat, Dec 24, 2022 at 4:12 AM Federico Valeri wrote:

Re: [VOTE] 3.3.2 RC1

2023-01-11 Thread Bruno Cadonna
Hi Chris and José, I think the issue is not Streams related but has to do with the following commit: commit b66af662e61082cb8def576ded1fe5cee37e155f (HEAD, tag: 3.3.2-rc1) Author: Chris Egerton Date: Wed Dec 21 16:14:10 2022 -0500 Bump version to 3.3.2 The Streams upgrade system

Re: [ANNOUNCE] New committer: Justine Olshan

2023-01-11 Thread Bruno Cadonna
Hi Justine, Re-reading my message I realized that my message might be misinterpreted. I meant that I am late with congratulating you due to the holidays, NOT that it took you long becoming a committer! Sorry for the potential confusion! Best, Bruno On 11.01.23 08:57, Bruno Cadonna wrote

Re: [DISCUSS] Add "Security Implications" section to KIP template

2023-01-12 Thread Bruno Cadonna
Hi Chris, Thank you for the proposal! Could you add some examples to each of your points? I think that would make it easier to discussion them. Best, Bruno On 12.01.23 03:15, Luke Chen wrote: Hi Chris, I like this idea. Thanks for raising this! One question to the template bullet: • Does

Re: [ANNOUNCE] New committer: Justine Olshan

2023-01-10 Thread Bruno Cadonna
Better late than never! Congrats! Best, Bruno On 04.01.23 20:25, Kirk True wrote: Congratulations! On Tue, Jan 3, 2023, at 7:34 PM, John Roesler wrote: Congrats, Justine! -John On Tue, Jan 3, 2023, at 13:03, Matthias J. Sax wrote: Congrats! On 12/29/22 6:47 PM, ziming deng wrote:

Re: [VOTE] KIP-878: Internal Topic Autoscaling for Kafka Streams

2022-12-08 Thread Bruno Cadonna
Thanks for the KIP! +1 (binding) Best, Bruno On 07.12.22 17:24, Matthias J. Sax wrote: +1 (binding) On 12/1/22 9:39 PM, Sophie Blee-Goldman wrote: Thanks to all who participated for a great discussion on this KIP. Seems we're ready to kick off the voting on this, but please don't hesitate

Re: [DISCUSS] KIP-889 Versioned State Stores

2022-12-19 Thread Bruno Cadonna
ernalTopicManager.java#L318-L319 ) but this method is not called from anywhere, even though there are unit tests for it. I was unable to find history of this validation after a quick search. Hopefully Matthias (or others) has context, otherwise I will have a closer look. - Victoria On We

Re: [VOTE] KIP-889 Versioned State Stores

2022-12-20 Thread Bruno Cadonna
Hi Victoria, Thanks for the KIP! +1 (binding) Best, Bruno On 19.12.22 20:03, Matthias J. Sax wrote: +1 (binding) On 12/15/22 1:27 PM, John Roesler wrote: Thanks for the thorough KIP, Victoria! I'm +1 (binding) -John On 2022/12/15 19:56:21 Victoria Xia wrote: Hi all, I'd like to start

Re: [ANNOUNCE] New committer: Viktor Somogyi-Vass

2022-12-15 Thread Bruno Cadonna
Congrats Viktor! Best, Bruno On 15.12.22 10:58, Viktor Somogyi-Vass wrote: Thank you everyone! :) On Thu, Dec 15, 2022 at 10:22 AM Mickael Maison wrote: Congratulations Viktor! On Thu, Dec 15, 2022 at 10:06 AM Tamas Barnabas Egyed wrote: Congratulations, Viktor!

Re: [ANNOUNCE] New committer: Ron Dagostino

2022-12-15 Thread Bruno Cadonna
Congrats Ron! Best, Bruno On 15.12.22 10:23, Viktor Somogyi-Vass wrote: Congrats Ron! :) On Thu, Dec 15, 2022 at 10:22 AM Mickael Maison wrote: Congratulations Ron! On Thu, Dec 15, 2022 at 9:41 AM Eslam Farag wrote: Congratulations, Ron ☺️ On Thu, 15 Dec 2022 at 10:40 AM Tom Bentley

Re: [ANNOUNCE] New committer: Josep Prat

2022-12-20 Thread Bruno Cadonna
Congrats, Josep! Well deserved! Best, Bruno On 20.12.22 18:40, Kirk True wrote: Congrats Josep! On Tue, Dec 20, 2022, at 9:33 AM, Jorge Esteban Quilcate Otoya wrote: Congrats Josep!! On Tue, 20 Dec 2022, 17:31 Greg Harris, wrote: Congratulations Josep! On Tue, Dec 20, 2022 at 9:29 AM

Re: [DISCUSS] KIP-889 Versioned State Stores

2022-11-23 Thread Bruno Cadonna
Hi all, Thanks for the KIP, Victoria! I have a couple of comments. 1. delete(key) I think delete(key) should not remove all versions of a key. We should use it to close the validity interval of the last version. Assuming we have records of different versions for key A: (A, e, 0, 2), (A, f,

Re: [DISCUSS] KIP-889 Versioned State Stores

2022-11-29 Thread Bruno Cadonna
nable to find history of this validation after a quick search. Hopefully Matthias (or others) has context, otherwise I will have a closer look. - Victoria On Wed, Nov 23, 2022 at 8:52 AM Bruno Cadonna wrote: Hi all, Thanks for the KIP, Victoria! I have a couple of comments. 1. delete(key) I thi

Re: [DISCUSS] Apache Kafka 3.3.2

2022-11-17 Thread Bruno Cadonna
Thanks for volunteering! +1 Best, Bruno On 17.11.22 09:57, Luke Chen wrote: Thanks for volunteering! On Thu, Nov 17, 2022 at 1:07 AM José Armando García Sancio wrote: +1. Thanks for volunteering. -- -José

Re: [DISCUSS] KIP-878: Autoscaling for Statically Partitioned Streams

2022-11-28 Thread Bruno Cadonna
iled" something like that 3. Could this operation get aborted? I don't think so. Maybe there should be a note in the KIP Thank you. Luke On Tue, Nov 1, 2022 at 2:15 AM Bruno Cadonna wrote: Hi Sophie, Thank you for the KIP! 1. I do not understand how autoscaling should work with a Str

Re: [VOTE] KIP-884: Add config to configure KafkaClientSupplier in Kafka Streams

2022-11-22 Thread Bruno Cadonna
Hi Hao, Thanks for the KIP! +1 (binding) Best, Bruno On 22.11.22 10:08, Sophie Blee-Goldman wrote: Hey Hao, thanks for the KIP -- I'm +1 (binding) On Mon, Nov 21, 2022 at 12:57 PM Matthias J. Sax wrote: +1 (binding) On 11/21/22 7:39 AM, John Roesler wrote: I'm +1 (binding) Thanks for

Re: [DISCUSS] Add "Security Implications" section to KIP template

2023-01-16 Thread Bruno Cadonna
at 3:51 AM Bruno Cadonna wrote: Hi Chris, Thank you for the proposal! Could you add some examples to each of your points? I think that would make it easier to discussion them. Best, Bruno On 12.01.23 03:15, Luke Chen wrote: Hi Chris, I like this idea. Thanks for raising this! On

Re: [ANNOUNCE] New committer: Walker Carlson

2023-01-18 Thread Bruno Cadonna
Congrats, Walker! Well deserved! Best, Bruno On 18.01.23 05:29, Sagar wrote: Congratulations Walker! Thanks! Sagar. On Wed, Jan 18, 2023 at 9:32 AM Tom Bentley wrote: Congratulations! On Wed, 18 Jan 2023 at 01:26, John Roesler wrote: Congratulations, Walker! -John On Tue, Jan 17,

Re: [ANNOUNCE] New committer: Stanislav Kozlovski

2023-01-17 Thread Bruno Cadonna
Congrats Stan! Well deserved! Best, Bruno On 17.01.23 16:50, Jun Rao wrote: Hi, Everyone, The PMC of Apache Kafka is pleased to announce a new Kafka committer Stanislav Kozlovski. Stan has been contributing to Apache Kafka since June 2018. He made various contributions including the

Re: [VOTE] KIP-869: Improve Streams State Restoration Visibility

2022-11-01 Thread Bruno Cadonna
Guozhang, Thanks for the KIP! +1 (binding) Best, Bruno On 25.10.22 22:07, Walker Carlson wrote: +1 non binding Thanks for the kip! On Thu, Oct 20, 2022 at 10:25 PM John Roesler wrote: Thanks for the KIP, Guozhang! I'm +1 (binding) -John On Wed, Oct 12, 2022, at 16:36, Nick Telford

Re: PR 12343 review/merge

2022-11-14 Thread Bruno Cadonna
Hi Jonathan, your PR was not approved by a committer. You need at least one approval from a committer on a PR. I left some comments. Best, Bruno On 10.11.22 18:15, Jonathan Albrecht wrote: Hi All, I have a PR https://github.com/apache/kafka/pull/12343 that was approved in June but has

<    1   2   3   4   5   6   7   >