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

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

[jira] [Resolved] (KAFKA-14120) Produce Kafka Streams Skipped Records Metrics

[ https://issues.apache.org/jira/browse/KAFKA-14120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-14120. --- Resolution: Not A Problem > Produce Kafka Streams Skipped Records Metr

Re: [ANNOUNCE] New Committer: Chris Egerton

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: Wiki permissions request

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

[jira] [Resolved] (KAFKA-13957) Flaky Test StoreQueryIntegrationTest.shouldQuerySpecificActivePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13957. --- Resolution: Fixed > Flaky T

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

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

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

[jira] [Resolved] (KAFKA-13930) Add 3.2.0 to broker/client and streams upgrade/compatibility tests

[ https://issues.apache.org/jira/browse/KAFKA-13930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13930. --- Resolution: Done > Add 3.2.0 to broker/client and streams upgrade/compatibility te

[jira] [Created] (KAFKA-14014) Flaky test NamedTopologyIntegrationTest.shouldAllowRemovingAndAddingNamedTopologyToRunningApplicationWithMultipleNodesAndResetsOffsets()

Bruno Cadonna created KAFKA-14014: - Summary: Flaky test NamedTopologyIntegrationTest.shouldAllowRemovingAndAddingNamedTopologyToRunningApplicationWithMultipleNodesAndResetsOffsets() Key: KAFKA-14014 URL: https

[jira] [Resolved] (KAFKA-13873) Add ability to Pause / Resume KafkaStreams Topologies

[ https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13873. --- Resolution: Fixed > Add ability to Pause / Resume KafkaStreams Topolog

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

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

[jira] [Resolved] (KAFKA-12657) Flaky Tests BlockingConnectorTest.testWorkerRestartWithBlockInConnectorStop

[ https://issues.apache.org/jira/browse/KAFKA-12657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-12657. --- Resolution: Fixed > Flaky Te

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

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: [VOTE] KIP-843: Adding metricOrElseCreate method to Metrics

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: [VOTE] KIP-846: Processor-level Streams metrics for records/bytes Producedd

+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: [VOTE] KIP-843: Adding metricOrElseCreate method to Metrics

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: [DISCUSS] KIP-846: Task-level Streams metrics for bytes/records Produced

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

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.

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: [DISCUSS] KIP-843 Adding metricOrElseCreate method to Metrics.

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

[jira] [Created] (KAFKA-13930) Add 3.2.0 to broker/client and streams upgrade/compatibility tests

Bruno Cadonna created KAFKA-13930: - Summary: Add 3.2.0 to broker/client and streams upgrade/compatibility tests Key: KAFKA-13930 URL: https://issues.apache.org/jira/browse/KAFKA-13930 Project: Kafka

Re: [ANNOUNCE] Apache Kafka 3.2.0

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: Permission request to contribute

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,

[ANNOUNCE] Apache Kafka 3.2.0

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

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

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

: 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: [ANNOUNCE] Apache Kafka 3.1.1

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

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: [kafka-clients] Re: [VOTE] 3.2.0 RC1

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: [DISCUSS] KIP-832 Allow creating a producer/consumer using a producer/consumer config

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: [DISCUSS] KIP-832 Allow creating a producer/consumer using a producer/consumer config

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] Apache Kafka 3.3.0 Release

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: [VOTE] KIP-834: Pause / Resume KafkaStreams Topologies

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: [VOTE] KIP-832 Allow creating a producer/consumer using a producer/consumer

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-834: Pause / Resume KafkaStreams Topologies

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: Contributor access

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-832 Allow creating a producer/consumer using a producer/consumer config

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

[RESULTS] [VOTE] Release Kafka version 3.2.0

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

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 >

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

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: [DISCUSS] KIP-832 Allow creating a producer/consumer using a producer/consumer config

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] 3.2.0 RC1

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

[VOTE] 3.2.0 RC1

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: [kafka-clients] Re: [VOTE] 3.2.0 RC0

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: [kafka-clients] Re: [VOTE] 3.2.0 RC0

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

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

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

://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

[VOTE] 3.2.0 RC0

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 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] KIP-825: introduce a new API to control when aggregated results are produced

and changed the title and text hoping it will start a new thread. Apparently it doesn't work... On Thu, Mar 24, 2022 at 12:36 PM Bruno Cadonna wrote: Hi Hao, Actually, this is the VOTE thread. Do you use GMail? Sometimes it is a bit weird how it shows e-mails in threads. Anyways, thank

[jira] [Resolved] (KAFKA-12774) kafka-streams 2.8: logging in uncaught-exceptionhandler doesn't go through log4j

[ https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-12774. --- Resolution: Cannot Reproduce > kafka-streams 2.8: logging in uncaught-exceptionhand

[jira] [Resolved] (KAFKA-13684) KStream rebalance can lead to JVM process crash when network issues occure

[ https://issues.apache.org/jira/browse/KAFKA-13684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13684. --- Resolution: Not A Bug > KStream rebalance can lead to JVM process crash when network iss

Re: newbie: PR 11955 review

Hi Rajani and Adam, I do not think "retest this" or any other comment works for non-committers anymore. Rajani, the failures seem to be flaky tests since they are unrelated to your change. Could you please look into JIRA for the flaky tests? You should find tickets that start with "Flaky

[jira] [Resolved] (KAFKA-13660) Replace log4j with reload4j

[ https://issues.apache.org/jira/browse/KAFKA-13660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13660. --- Resolution: Fixed > Replace log4j with reloa

Re: [DISCUSS] Apache Kafka 3.2.0 release

that were aimed for 3.2.0 to the next major release. Please help testing the release and notify this thread if you find any regression/blocker. Best, Bruno On 21.03.22 22:22, Bruno Cadonna wrote: Hi Kafkateers, Last week we reached feature freeze for the next major release of Apache

Re: kafka | jackson-databind | CVE-2020-36518

Hi Islam Thank you for the notification! I just merged https://github.com/apache/kafka/pull/11962 which fixes CVE-2020-36518. Best, Bruno On 30.03.22 20:48, Islam Farag wrote: Hello, Need to report a vulnerability that

[jira] [Resolved] (KAFKA-13775) CVE-2020-36518 - Upgrade jackson-databind to 2.12.6.1

[ https://issues.apache.org/jira/browse/KAFKA-13775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13775. --- Resolution: Fixed > CVE-2020-36518 - Upgrade jackson-databind to 2.12.

[jira] [Resolved] (KAFKA-13776) Update rocksdb to support arm64 M1 Mac

[ https://issues.apache.org/jira/browse/KAFKA-13776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13776. --- Resolution: Fixed > Update rocksdb to support arm64 M1

[jira] [Resolved] (KAFKA-13600) Rebalances while streams is in degraded state can cause stores to be reassigned and restore from scratch

[ https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13600. --- Resolution: Fixed > Rebalances while streams is in degraded state can cause sto

[jira] [Reopened] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reopened KAFKA-13736: --- > Flaky kafka.network.SocketServerTest.closingChannelWithBufferedRecei

[jira] [Resolved] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13736. --- Resolution: Fixed > Flaky kafka.network.SocketServerTest.closingChannelWithBufferedRecei

[jira] [Resolved] (KAFKA-13735) Flaky kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13735. --- Resolution: Fixed > Flaky kafka.network.SocketServerTest.remoteCloseWithoutBufferedRecei

Re: [VOTE] KIP-825: introduce a new API to control when aggregated results are produced

Hi Hao, Actually, this is the VOTE thread. Do you use GMail? Sometimes it is a bit weird how it shows e-mails in threads. Anyways, thank you for the KIP and your patience! +1 (binding) Best, Bruno On 24.03.22 17:36, Hao Li wrote: Thanks John and Guozhang. Didn't realize I used this

[jira] [Resolved] (KAFKA-13128) Flaky Test StoreQueryIntegrationTest.shouldQueryStoresAfterAddingAndRemovingStreamThread

[ https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13128. --- Resolution: Fixed > Flaky T

Re: [DISCUSS] Apache Kafka 3.2.0 release

production code, or removing the test. Besides the flaky tests, also the other blocker tickets and critical tickets need some attention. Best, Bruno On 21.03.22 22:22, Bruno Cadonna wrote: Hi Kafkateers, Last week we reached feature freeze for the next major release of Apache Kafka. I cut

Re: [DISCUSS] KIP-825: introduce a new API to control when aggregated results are produced

lax the principle given the benefits compared to option 2)? Maybe John can chime in as the DSL grammar author. Thanks, Hao On Wed, Mar 23, 2022 at 2:59 AM Bruno Cadonna wrote: Hi Hao, I agree with Guozhang: Great summary! Thank you! Regarding "aligned with other config class nam

Re: [DISCUSS] KIP-825: introduce a new API to control when aggregated results are produced

ation is triggered on window close and all aggregation results are emitted." for trigger(TriggerParameters.onWindowClose()), and "the aggregation is configured to only emit final results." for trigger(Emitted.onWindowClose())? On Tue, Mar 22, 2022 at 4:19 AM Bruno Cadonna wrote

Re: [DISCUSS] KIP-825: introduce a new API to control when aggregated results are produced

or trigger(TriggerParameters.onWindowClose()), and "the aggregation is configured to only emit final results." for trigger(Emitted.onWindowClose())? On Tue, Mar 22, 2022 at 4:19 AM Bruno Cadonna wrote: Hi Hao, Thank you for the KIP! Regarding option 1, I would not use `Emitted.onWindowClose()` sinc

Re: [VOTE} KIP-796: Interactive Query v2

t's listed in the "Rejected Alternatives" section. Thanks, Bill On Mon, Nov 22, 2021 at 9:22 AM Bruno Cadonna wrote: Thanks for the KIP, John! +1 (binding) Best, Bruno On 19.11.21 18:04, Vasiliki Papavasileiou wrote: I think this KIP will greatly improve how we handle IQ in streams so +1 (

Re: [DISCUSS] KIP-825: introduce a new API to control when aggregated results are produced

Hi Hao, Thank you for the KIP! Regarding option 1, I would not use `Emitted.onWindowClose()` since that does not seem compatible with the proposed flow. Conceptually, now the flow states that the aggregation is triggered on window close and all aggregation results are emitted. `Emitted`

Re: [DISCUSS] Apache Kafka 3.2.0 release

%20%20%20%20%20%20%20%20 Best, Bruno On 15.03.22 15:11, Bruno Cadonna wrote: Hi all, A quick reminder that feature freeze for Apache 3.2.0 is tomorrow. Please make sure to get your features merged into trunk. I will cut the release branch on Monday. Best, Bruno On 07.03.22 15:03, Bruno

[jira] [Resolved] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-6718. -- Resolution: Fixed > Rack Aware Stand-by Task Assignment for Kafka Stre

Re: [DISCUSS] Apache Kafka 3.2.0 release

of a feature needs to be merged into trunk before the cut of the release branch. Best, Bruno On 15.03.22 16:13, Levani Kokhreidze wrote: Hi Bruno, I assume we will be able to merge changes tomorrow as well? Thanks, Levani On 15. Mar 2022, at 16:11, Bruno Cadonna wrote: Hi all, A quick reminder

Re: [DISCUSS] Apache Kafka 3.2.0 release

Hi all, A quick reminder that feature freeze for Apache 3.2.0 is tomorrow. Please make sure to get your features merged into trunk. I will cut the release branch on Monday. Best, Bruno On 07.03.22 15:03, Bruno Cadonna wrote: Hi Kafkateers, Last week we reached KIP freeze for the next

Re: [kafka-clients] [ANNOUNCE] Apache Kafka 3.0.1

, Netflix, Pinterest, Rabobank, Target, The New York Times, Uber, Yelp, and Zalando, among others. A big thank you for the following 26 contributors to this release! A. Sophie Blee-Goldman, Andras Katona, Bruno Cadonna, Chris Egerton, Cong Ding, David Jacot, dengziming, Edoardo Comar, Ismael Juma

Re: [DISCUSS] Apache Kafka 3.1.1

Thank you, Tom! +1 Best, Bruno On 09.03.22 19:55, David Jacot wrote: +1. Thanks Tom! Le mer. 9 mars 2022 à 19:10, Bill Bejeck a écrit : Thanks Tom! It's a +1 for me. -Bill On Wed, Mar 9, 2022 at 12:00 PM Ismael Juma wrote: Thanks Tom. +1 Ismael On Wed, Mar 9, 2022 at 8:10 AM Tom

Re: [DISCUSS] Apache Kafka 3.2.0 release

plan. For the KIPs which are still in progress, please work closely with your reviewers to make sure that they land on time for the feature freeze. The next milestone for the AK 3.2.0 release is feature freeze on March 16th 2022. Best, Bruno On 01.03.22 17:41, Bruno Cadonna wrote: Hi all

[jira] [Resolved] (KAFKA-13658) Upgrade vulnerable dependencies jan 2022

[ https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13658. --- Resolution: Fixed > Upgrade vulnerable dependencies jan 2

Re: [DISCUSS] Apache Kafka 3.2.0 release

tps://cwiki.apache.org/confluence/display/KAFKA/KIP-815:++Support+max-timestamp+in+GetOffsetShell> The vote has passed just 2 days ago. — Thanks, Ziming Deng On Mar 2, 2022, at 12:41 AM, Bruno Cadonna wrote: Hi all, A quick reminder that KIP freeze for the Apache 3.2.0 is tomorrow. Please make

Re: [DISCUSS] Apache Kafka 3.2.0 release

Hi all, A quick reminder that KIP freeze for the Apache 3.2.0 is tomorrow. Please make sure to close your votes if you want to add a KIP to the release plan. Best, Bruno On 15.02.22 12:37, Bruno Cadonna wrote: Hi all, I published a release plan for the Apache Kafka 3.2.0 release here

[jira] [Resolved] (KAFKA-13542) Utilize the new Consumer#enforceRebalance(reason) API in Streams

[ https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13542. --- Resolution: Fixed > Utilize the new Consumer#enforceRebalance(reason) API in Stre

Re: [DISCUSS] KIP-761: Add total blocked time metric to streams

Hi Rohan, Thank you for the heads up! Yes, please update the KIP and send this message also to the VOTE thread of the KIP. Best, Bruno On 25.02.22 04:01, Rohan Desai wrote: Hello, I discovered a bug in the design of this metric. The bug is documented here:

[jira] [Resolved] (KAFKA-12260) PartitionsFor should not return null value

[ https://issues.apache.org/jira/browse/KAFKA-12260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-12260. --- Resolution: Fixed > PartitionsFor should not return null va

[jira] [Resolved] (KAFKA-13666) Tests should not ignore exceptions for supported OS

[ https://issues.apache.org/jira/browse/KAFKA-13666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13666. --- Resolution: Fixed > Tests should not ignore exceptions for supported

Re: [DISCUSS] Apache Kafka 3.2.0 release

+Configurable+backlog+size+for+creating+Acceptor ) Thanks, 2022年2月16日(水) 18:22 Bruno Cadonna : Hi Julien, Thank you for the feedback on the release plan. I added KIP-808 to the plan. Best, Bruno On 16.02.22 09:10, Julien Chanaud wrote: Hello Bruno, Can we also add KIP-808 to the plan ? https

[jira] [Created] (KAFKA-13672) Flaky test kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize()

Bruno Cadonna created KAFKA-13672: - Summary: Flaky test kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize() Key: KAFKA-13672 URL: https://issues.apache.org/jira/browse/KAFKA-13672

Re: [DISCUSS] Apache Kafka 3.2.0 release

+precisions+in+TimestampConverter+SMT Thank you, Julien Le mar. 15 févr. 2022 à 19:01, Mickael Maison a écrit : Hi Bruno, Thanks for publishing the release plan! Can we add KIP-769 to the plan? Thanks, Mickael On Tue, Feb 15, 2022 at 12:37 PM Bruno Cadonna wrote: Hi all, I published a release

Re: [DISCUSS] Apache Kafka 3.2.0 release

Hi Mickael, Thank you for your feedback on the release plan! I added KIP-769 to the plan. Best, Bruno On 15.02.22 19:00, Mickael Maison wrote: Hi Bruno, Thanks for publishing the release plan! Can we add KIP-769 to the plan? Thanks, Mickael On Tue, Feb 15, 2022 at 12:37 PM Bruno Cadonna

Re: [DISCUSS] Apache Kafka 3.2.0 release

. Please let me know if should add or remove KIPs from the plan or if you have any other objections. Best, Bruno On 04.02.22 16:03, Bruno Cadonna wrote: Hi, I'd like to volunteer to be the release manager for our next feature release, 3.2.0. If there are no objections, I'll send out

[jira] [Resolved] (KAFKA-6823) Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize

[ https://issues.apache.org/jira/browse/KAFKA-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-6823. -- Resolution: Fixed > Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolRes

[jira] [Resolved] (KAFKA-8153) Streaming application with state stores takes up to 1 hour to restart

[ https://issues.apache.org/jira/browse/KAFKA-8153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8153. -- Resolution: Not A Problem > Streaming application with state stores takes up to 1 h

Re: [ANNOUNCE] New committer: Luke Chen

Congrats, Luke! Very well deserved! Best, Bruno On 10.02.22 09:20, Manikumar wrote: Congrats Luke! On Thu, Feb 10, 2022 at 1:36 PM Mickael Maison wrote: Congratulations Luke! On Thu, Feb 10, 2022 at 8:54 AM Tom Bentley wrote: Congratulations Luke! On Thu, 10 Feb 2022 at 06:41, Josep

Re: Kafka <= 3.1 upgrade RocksDB to v6.27.3?

that would be solved by back porting. I understand there are risks and it might not be appropriate for a bugfix release which is why I wanted to ask first before going any further. Thanks, Jon "Bruno Cadonna" wrote on 2022-02-07 05:30:05 AM: From: "Bruno Cadonna" To: dev@kafka.a

Re: [DISCUSS] Apache Kafka 3.0.1

+1 Thank you! Best, Bruno On 07.02.22 18:24, Ismael Juma wrote: Thanks Mickael, +1. Ismael On Mon, Feb 7, 2022 at 9:17 AM Mickael Maison wrote: Hi, I'd like to volunteer to be the release manager for the next bugfix release, 3.0.1. Thanks, Mickael

Re: [DISCUSS] Should we automatically close stale PRs?

Hi, Thank you David for bringing this up! I am in favour of automatically closing stale PRs. I agree with Guozhang that notifications of staleness to authors would be better than silently closing them. I assume the notification happens automatically when the label "Stale" is added to the PR.

Re: Kafka <= 3.1 upgrade RocksDB to v6.27.3?

Bruno. In that case, if no other concerns, I'll try updating RocksDB to v6.27.3 on the 3.0 and 3.1 branches and file issues and PRs if everything looks good. Jon "Bruno Cadonna" wrote on 2022-02-03 10:40:00 AM: From: "Bruno Cadonna" To: dev@kafka.apache.org Date: 202

[DISCUSS] Apache Kafka 3.2.0 release

Hi, I'd like to volunteer to be the release manager for our next feature release, 3.2.0. If there are no objections, I'll send out the release plan soon. Best, Bruno

Re: Kafka <= 3.1 upgrade RocksDB to v6.27.3?

Hi Jonathan, We had to wait until AK 3.0 to upgrade RocksDB to 6.19.3 due to source compatibility issue. More specifically, we expose RocksDB APIs in Kafka Streams for configuring RocksDB and those RocksDB APIs changed. So upgrading RocksDB was actually a compatibility breaking change. We had

[jira] [Resolved] (KAFKA-13599) Upgrade RocksDB to 6.27.3

[ https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-13599. --- Resolution: Resolved > Upgrade RocksDB to 6.2

Re: Please add jonathan.albrecht to the contributer's group in jira

Hi Jonathan, I added you to the contributors group. You are now able to assign tickets to yourself. Thank you for your interest in Apache Kafka! Best, Bruno On 18.01.22 18:02, Jonathan Albrecht wrote: Hello Team, I'd like to contribute to kafka. Could I be added to the contributer's

Re: Need access to Apache Kafka JIRA - username - manojp111

Hi Manoj, I added you to the contributor's group in JIRA. You should now be able to assign tickets to yourself. Thank you for your interest! Best, Bruno On 17.01.22 02:58, Manoj Pardeshi wrote: Hi Apache Kafka moderators, Please give access to JIRA so that I can contribute to the project.

<    1   2   3   4   5   6   7   >