Hi Matthew,
I added you to the list of contributors in JIRA. You can now assign
tickets to yourself.
Thank you for your interest in Apache Kafka.
Best,
Bruno
On 18.05.21 16:57, Matthew de Detrich wrote:
Hello,
I would like to start contributing to Apache Kafka, could you add my
username (m
Hey Leah,
> what I think should be a small discussion
Dangerous words, indeed! It seems like they trigger something in people ;-)
Jokes apart!
Did you consider throwing a more specific exception instead of a
StreamsException? Something that describes better the issue at hand.
Best,
Bruno
ception? WDYT? I was hoping that with
the
message the streams exception would still give enough information for
users
to debug the problem.
Still hoping for a short discussion (; but thanks for the input so far!
Leah
On Wed, May 19, 2021 at 3:00 AM Bruno Cadonna
wrote:
Hey Leah,
> w
Thanks for the KIP, Sophie!
+1 (binding)
Note:
The sentence in the KIP seems to need some corrections:
"To migrate from the String to TaskIdInfo in TaskMetadata, we'll need to
deprecate the existing taskId() getter method and add a TaskId() getter
in its place."
I guess you wanted to write:
Hi,
I would like to propose KIP-743 to deprecate the old structures of the
built-in metrics in Streams.
https://cwiki.apache.org/confluence/x/uIfOCg
Best,
Bruno
to "latest" already.
If you do agree that we can treat it as having been
deprecated since 2.5, I'd further suggest that we no longer
need the "built.in.metrics.version" config at all.
WDYT?
Thanks,
John
On Thu, 2021-05-20 at 13:57 +0200, Bruno Cadonna wrote:
Hi,
I wo
Hi,
I'd like to start a vote on KIP-743 that proposes to remove config value
0.10.0-2.4 from Streams config built.in.metrics.version.
https://cwiki.apache.org/confluence/x/uIfOCg
Best,
Bruno
-Goldman wrote:
+1 (binding)
Thanks Bruno!
On Fri, May 21, 2021 at 8:06 AM Guozhang Wang wrote:
+1, thanks!
On Fri, May 21, 2021 at 12:45 AM Bruno Cadonna wrote:
Hi,
I'd like to start a vote on KIP-743 that proposes to remove config value
0.10.0-2.4 from Streams c
Hi Dongjin,
voting for a KIP needs to remain open for at least 72 hours [1].
According to the date and time of the first message to this thread 72
hours havn't passed, yet. Theoretically, there could still be -1 votes
coming in.
Best,
Bruno
[1]
https://cwiki.apache.org/confluence/display/K
Hi Leah,
Thanks for the KIP!
+1 (binding)
Best,
Bruno
On 25.05.21 14:02, Bruno Cadonna wrote:
Hi Dongjin,
voting for a KIP needs to remain open for at least 72 hours [1].
According to the date and time of the first message to this thread 72
hours havn't passed, yet. Theoretically,
Hi Josep,
Thank you for the KIP!
Specifying TaskMetadata as an interface lifts the guarantee that
equals() and hashCode() on the TaskMetadata return consistent values for
the same content. Note that the current TaskMetadata implements both
methods, so theoretically users might already rely on
Thanks, Josep!
+1 (binding)
Bruno
On 04.06.21 10:27, Josep Prat wrote:
Hi all,
I'd like to call for a vote on KIP-744: Migrate TaskMetadata and
ThreadMetadata to an interface with internal implementation
KIP page can be found here: https://cwiki.apache.org/confluence/x/XIrOCg
Discussion thread
Hi Ismael,
Thank you for the KIP!
+1 (binding)
Best,
Bruno
On 08.06.21 10:11, Matthew de Detrich wrote:
+1 (non binding)
On Tue, Jun 8, 2021 at 4:48 AM Luke Chen wrote:
Hi Ismael,
Thanks for the KIP.
+1 (non-binding)
Thanks.
Luke
On Tue, Jun 8, 2021 at 7:18 AM Konstantine Karantasis
wr
Hi Ismael,
Thank you for the KIP!
+1 (binding)
Best,
Bruno
On 08.06.21 10:11, Matthew de Detrich wrote:
+1 (non binding)
On Tue, Jun 8, 2021 at 4:34 AM Luke Chen wrote:
Hi Ismael,
Thanks for the KIP!
+1 (non-binding)
Thanks.
Luke
On Tue, Jun 8, 2021 at 8:16 AM Israel Ekpo wrote:
I su
Hi Garmes,
I gave you the requested permissions.
Thank you for your interest in Apache Kafka!
Best,
Bruno
On 16.06.21 09:40, Garmes Amine wrote:
Wiki ID: mgarmes
I need to create a new KIP page.
Thank you for your help!
Garmes
Hi Konstantine,
The implementation of
KIP-698: Add Explicit User Initialization of Broker-side State to Kafka
Streams
will not be ready for 3.0, so you can remove it from the list.
Best,
Bruno
On 15.06.21 07:33, Konstantine Karantasis wrote:
Done. Moved it into the table of Adopted KIPs targ
Congrats Konstantine!
Best,
Bruno
On 21.06.21 20:10, Randall Hauch wrote:
Congratulations, Konstantine!
On Mon, Jun 21, 2021 at 12:39 PM Walker Carlson
wrote:
Congratulations!
On Mon, Jun 21, 2021 at 12:25 PM Dhruvil Shah
wrote:
Congratulations Konstantine! Well deserved!
On Mon, Jun
Hi Ivan,
Thank you for the KIP!
Some aspects are not clear to me from the KIP and I have a proposal.
1. The KIP does not describe the criteria that define a duplicate. Could
you add a definition of duplicate to the KIP?
2. The KIP does not describe what happens if distinct() is applied on a
thing. I thought Ivan was just saying that it doesn't
make a ton of sense to use it, which I agree with, but it doesn't seem like
that means we should prohibit it.
3. FWIW, I don't have a strong feeling either way.
Thanks,
-John
On Mon, Jul 12, 2021, at 09:14, Bruno Cadonna wrote:
Thanks for the KIP, Patrick!
I agree with John that your KIP is well motivated.
I have just one minor feedback. Could you add store.range(null, null) to
the example snippets with the comment that this is equivalent to all()
(it is equivalent, right?)? This question about equivalence between
r
Hi Patrick,
Thank you for the KIP!
+1 (binding)
Best,
Bruno
On 22.07.21 03:47, Luke Chen wrote:
Hi Patrick,
I like this KIP!
+1 (non-binding)
Luke
On Thu, Jul 22, 2021 at 7:04 AM Matthias J. Sax wrote:
Thanks for the KIP.
+1 (binding)
-Matthias
On 7/21/21 1:18 PM, Patrick Stuedi wro
Hi Rohan,
Thank you for the KIP!
I agree that the KIP is well-motivated.
What is not very clear is the metadata like type, group, and tags of the
metrics. For example, there is not application-id tag in Streams and
there is also no producer-id tag. The clients, i.e., producer, admin,
consume
ave a strong feeling either way.
Thanks,
-John
On Mon, Jul 12, 2021, at 09:14, Bruno Cadonna wrote:
Hi Ivan,
Thank you for the KIP!
Some aspects are not clear to me from the KIP and I have a proposal.
1. The KIP does not describe the criteria that define a duplicate. Could
you add a definition
e "niche"?
It sounds like maybe DEBUG would be most appropriate here -- WDYT?
-Sophie
On Thu, Jul 22, 2021 at 9:01 AM Bruno Cadonna wrote:
Hi Rohan,
Thank you for the KIP!
I agree that the KIP is well-motivated.
What is not very clear is the metadata like type, group, and tags of
Thank you Rohan,
+1 (binding)
Best,
Bruno
On 02.08.21 17:54, Israel Ekpo wrote:
Rohan,
Thanks for working on this. Looks great.
+1 from me. (non-binding)
Don't forget to update the *Current State* of the KIP and include the
associated *JIRA IDs* once the voting is completed.
https://cwiki.
Hi Christo,
I stopped the build and restarted it. Hopefully, this time it will not
get stuck.
Best,
Bruno
On 25.08.21 08:14, Josep Prat wrote:
Hi Christo,
The easiest two ways to re-trigger the builds that I found are:
— Close and open the Pull Request. Jenkins should pick this event up
— A
Hi,
You are all set now!
Happy contributing!
Bruno
On 06.09.21 08:13, felixzh wrote:
Hi,
I'd like to request permissions to contribute to Kafka to propose a KIP.
Wiki ID: felixzh
Jira ID: felixzh
Thanks you
Thanks, Josep!
+1 (binding)
Best,
Bruno
On 04.09.21 05:55, Sagar wrote:
Looks good to me.
+1(non-binding)
Sagar.
On Sat, 4 Sep 2021 at 8:15 AM, Luke Chen wrote:
Thanks for the KIP.
+1 (non-binding)
Thanks.
Luke
On Sat, Sep 4, 2021 at 10:32 AM Guozhang Wang wrote:
Thanks Josep,
Too
Hi Luiz,
You are now a contributor in JIRA and can assign tickets to yourself.
Best,
Bruno
On 17.09.21 00:36, Luiz Fernando Fonseca wrote:
Hello. I would like to become a contributor in JIRA.
Username: luizfrf
Best Regards,
Hi Christopher,
Great that you want to contribute to the Apache Kafka project.
A good place to start is https://kafka.apache.org/contributing
Read the instructions there to set yourself up.
Looking forward to your contributions,
Bruno
On 17.09.21 11:14, Christopher X Bogan wrote:
Hi I woul
Hi David,
Thank you for the plan!
KIP-698 will not make it for 3.1.0. Could you please remove it from the
plan?
Best,
Bruno
On 24.09.21 16:22, David Jacot wrote:
Hi all,
I just published a release plan here:
https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+3.1.0
The plan sug
Hi,
You should be all set up, now!
Thank you for your interest in Apache Kafka!
Best,
Bruno
On 11.10.21 22:44, Mason Legere wrote:
Hi, I am requesting access in order to make contributions to Kafka. My Jira
and Wiki ID are both "masonlegere"
Best,
Hi Vicky,
You are all setup now!
Best,
Bruno
On 04.11.21 11:40, Vasiliki Papavasileiou wrote:
Wiki ID: vicky_papavas
Jira ID: vicky_papavas
Hi Patrick,
Thank you for the KIP!
- Maybe some more details in the motivation would help to better
understand the background of the KIP. Currently, it is hard to judge
whether record metadata should be exposed or not. Can you maybe give an
example?
- Could you please replace RYW abbreviati
Patrick,
Thank you for the KIP!
+1 (binding)
Best,
Bruno
On 09.11.21 16:58, John Roesler wrote:
+1 (binding) from me.
Thanks, Patrick!
On Mon, 2021-11-08 at 14:08 -0800, Guozhang Wang wrote:
+1, thanks Patrick!
Guozhang
On Mon, Nov 8, 2021 at 5:44 AM Vasiliki Papavasileiou
wrote:
Hi
Tom,
Congratulations!
Best,
Bruno
On 18.11.21 17:12, David Jacot wrote:
Congrats, Tom!
On Thu, Nov 18, 2021 at 5:03 PM Mickael Maison wrote:
Congratulations Tom!
On Thu, Nov 18, 2021 at 4:54 PM Chris Egerton
wrote:
Congrats Tom!
On Thu, Nov 18, 2021 at 10:49 AM Jun Rao wrote:
Hi, E
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
(non-binding) from me.
Thank you John!
On Thu, Nov 18, 2021 at 9:45 PM Patrick Stuedi
wrote:
+1 (non-binding), thanks
Hi Prem,
I added you to the contributor group in Jira. You should be able to
assign tickets to yourself, now.
Looking forward to your contributions.
Best,
Bruno
On 04.12.21 19:31, Prem Kamal wrote:
Hey folks,
I am willing to contribute to Apache Kafka.
Please, can you grant me contributo
Hi Anshul,
I granted you the requested permissions in Jira and wiki.
Looking forward to your contributions!
Best,
Bruno
On 05.12.21 08:29, Anshul Gangwal wrote:
Hi Admins,
I would like to sign-up as a Kafka contributor.
Could you grant me contributor access in wiki and Jira?
ID: anshulsg
Th
Hi Mickael,
I agree that your proposal would be useful.
Thank you for starting this.
Best,
Bruno
On 14.12.21 15:55, Luke Chen wrote:
Hi Mickael,
I love this idea.
That would be very helpful for reviewers to check the original problem
description in JIRA.
Thank you for raising this!
Luke
O
Hi Luke,
I am afraid the ConsumerRebalanceListener will not work in this case
since Boyuan assigns the partitions manually. The Java docs you linked state
If the consumer directly assigns partitions, those partitions will never
be reassigned and this callback is not applicable.
Hi Boyuan,
Hi Team HirinGuru,
if you want to unsubscribe, see the description on how to do that on
https://kafka.apache.org/contact
Best,
Bruno
On 22.01.21 07:41, Hiringuru wrote:
Hi,
Kindly unsubscribe our email from your daily notification. We don't want to
receive any further notification.
I woul
me. I think it would not change any StreamThread
implementation regarding capturing exceptions from consumer.poll() since it
captures StreamsException as fatal.
Guozhang
On Wed, Dec 16, 2020 at 4:43 AM Bruno Cadonna wrote:
Hi Guozhang,
Thank for the feedback!
Please find my answers inline.
the timeout is exceeded.
We updated the KIP accordingly.
KIP: https://cwiki.apache.org/confluence/x/FDd4CQ
Best,
Bruno
On 30.09.20 13:51, Bruno Cadonna wrote:
Thank you all for voting!
This KIP is accepted with 3 binding +1 (Guozhang, John, Matthias).
Best,
Bruno
On 29.09.20 22:24, Matthias
;m +1 (binding)
-John
On Wed, 2021-01-27 at 14:18 -0600, Leah Thomas wrote:
Hi Bruno,
I'm still +1, non-binding. Thanks for the updates!
Leah
On Wed, Jan 27, 2021 at 1:56 PM Matthias J. Sax
wrote:
Thanks for updating the KIP.
+1 (binding)
-Matthias
On 1/27/21 10:19 AM, Bruno Cad
Hi Levani,
Thank you for the KIP.
Really interesting!
Here my comments:
1. To be consistent with the other configs that involve standbys , I
would rename
standby.task.assignment.awareness -> standby.replicas.awareness
2. I would also rename the prefix
instance.tag -> client.tag
3. The foll
aTasks and
HighAvailabilityTaskAssignor#assignStandbyTaskMovements
I hope this answers your questions.
Regards,
Levani
On 18. Feb 2021, at 15:10, Bruno Cadonna wrote:
Hi Levani,
Thank you for the KIP.
Really interesting!
Here my comments:
1. To be consistent with the other configs that involve st
-PartiallyPreferredStandbyTaskDistribution
Regards,
Levani
On 22. Feb 2021, at 16:51, Bruno Cadonna wrote:
Hi Levani,
Thanks for the modifications!
I have some follow up questions/comments:
5. Something is not clear to me. If the active is on Node-1 and the first
replica is on Node-5
Please let me know if the latest version looks OK.
Regards,
Levani
[1]
https://cwiki.apache.org/confluence/display/KAFKA/KIP-708%3A+Rack+awarness+for+Kafka+Streams
On 25. Feb 2021, at 17:59, Bruno Cadonna wrote:
Hi Levani,
I discussed your KIP with John the other day and we both think it i
Hi Walker,
Thank you for the KIP!
I somehow agree that we should document that some tasks may be missing.
I have one question/comment. As far as I understand, your KIP adds two
methods that return data that is actually hosted on the brokers, namely
committedOffsets() and endOffsets(). Thus, w
KIP [1] based on suggestions.
Regards,
Levani
[1] -
https://cwiki.apache.org/confluence/display/KAFKA/KIP-708%3A+Rack+awarness+for+Kafka+Streams
<https://cwiki.apache.org/confluence/display/KAFKA/KIP-708:+Rack+awarness+for+Kafka+Streams>
On 1. Mar 2021, at 22:55, Bruno Cadonna mailto:br..
Hi Levani,
Thanks for the KIP!
+1 (non-binding)
Best,
Bruno
On 10.03.21 12:13, Levani Kokhreidze wrote:
Hello all,
I’d like to start the voting on KIP-708 [1]
Best,
Levani
[1] -
https://cwiki.apache.org/confluence/display/KAFKA/KIP-708%3A+Rack+awareness+for+Kafka+Streams
Congrats, Chia-Ping!
Best,
Bruno
On 15.03.21 09:22, David Jacot wrote:
Congrats Chia-Ping! Well deserved.
On Mon, Mar 15, 2021 at 5:39 AM Satish Duggana
wrote:
Congrats Chia-Ping!
On Sat, 13 Mar 2021 at 13:34, Tom Bentley wrote:
Congratulations Chia-Ping!
On Sat, Mar 13, 2021 at 7:31 A
Congrats, Tom!
Best,
Bruno
On 15.03.21 18:59, Mickael Maison wrote:
Hi all,
The PMC for Apache Kafka has invited Tom Bentley as a committer, and
we are excited to announce that he accepted!
Tom first contributed to Apache Kafka in June 2017 and has been
actively contributing since February 20
Hi Sophie,
I am +1, for explicitly documenting that this list must be identical in
contents and order across all clients in the application in the KIP. And
later in the docs of the config. If we are too much concerned about this
and we think that we should explicitly check the order and conten
Forgot to say ...
I am fine with the rest of the name you proposed, i.e.,
"task.rack.aware.assignment.tags".
Best,
Bruno
On 16.03.21 09:30, Bruno Cadonna wrote:
Hi Sophie,
I am +1, for explicitly documenting that this list must be identical in
contents and order across all clie
nse about purposely excluding "standby" from the config name.
In that case
I would be happy with just "task.rack.aware.assignment.tags", although I'd
propose to shorten
it further by removing the "task" part of "standby.task" as well, ie just
"rack.aw
Hi Sophie,
Please have a look at the following bug report:
https://issues.apache.org/jira/browse/KAFKA-12508
I set its priority to blocker since the bug might break at-least-once
and exactly-once processing guarantees.
Feel free to set it back to major, if you think that it is not a blocker.
Hi Mickael,
Please have a look at the following bug report:
https://issues.apache.org/jira/browse/KAFKA-12508
I set its priority to blocker since the bug might break at-least-once
and exactly-once processing guarantees.
Feel free to set it back to major, if you think that it is not a blocker
Hi John,
Please have a look at the following bug report:
https://issues.apache.org/jira/browse/KAFKA-12508
I set its priority to blocker since the bug might break at-least-once
and exactly-once processing guarantees.
Feel free to set it back to major, if you think that it is not a blocker.
Hi John,
Correction to my last e-mail: The bug does not break eos, but it breaks
at-least-once.
Bruno
On 19.03.21 14:55, Bruno Cadonna wrote:
Hi John,
Please have a look at the following bug report:
https://issues.apache.org/jira/browse/KAFKA-12508
I set its priority to blocker since
Hi Sophie,
Correction to my last e-mail: The bug does not break eos, but it breaks
at-least-once.
Bruno
On 19.03.21 14:54, Bruno Cadonna wrote:
Hi Sophie,
Please have a look at the following bug report:
https://issues.apache.org/jira/browse/KAFKA-12508
I set its priority to blocker since
Hi Mickael,
Correction to my last e-mail: The bug does not break eos, but it breaks
at-least-once.
Bruno
On 19.03.21 14:54, Bruno Cadonna wrote:
Hi Mickael,
Please have a look at the following bug report:
https://issues.apache.org/jira/browse/KAFKA-12508
I set its priority to blocker
Congrats Bill! Well deserved!
Best,
Bruno
On 12.04.21 11:19, Satish Duggana wrote:
Congratulations Bill!!
On Thu, 8 Apr 2021 at 13:24, Tom Bentley wrote:
Congratulations Bill!
On Thu, Apr 8, 2021 at 2:36 AM Luke Chen wrote:
Congratulations Bill!
Luke
On Thu, Apr 8, 2021 at 9:17 AM Mat
Thank you all for the kind words!
Best,
Bruno
On 08.04.21 00:34, Guozhang Wang wrote:
Hello all,
I'm happy to announce that Bruno Cadonna has accepted his invitation to
become an Apache Kafka committer.
Bruno has been contributing to Kafka since Jan. 2019 and has made 99
commits and
Hi Sophie,
the KIP makes sense to me! Thank you for writing it!
Best,
Bruno
On 14.04.21 04:52, Sophie Blee-Goldman wrote:
Hey all,
I'd like to kick off discussion on a small KIP to move towards a unified
EOS and clean up the current options. Please give it a pass and let me know
what you thin
Sophie,
Thank you for the KIP!
+1 (binding)
Best,
Bruno
On 15.04.21 01:59, Sophie Blee-Goldman wrote:
Hey all,
I'd like to kick off the vote on KIP-732, to deprecate eos-alpha in Kafka
Streams and migrate away from the "eos-beta" terminology by replacing it
with "eos-v2" to shore up user con
Sophie,
Thank you for the KIP!
+1 (binding)
Best,
Bruno
On 15.04.21 01:59, Sophie Blee-Goldman wrote:
Hey all,
I'd like to kick off the vote on KIP-732, to deprecate eos-alpha in Kafka
Streams and migrate away from the "eos-beta" terminology by replacing it
with "eos-v2" to shore up user con
Thanks Matthias,
+1 (binding)
Best,
Bruno
On 16.04.21 01:03, Jorge Esteban Quilcate Otoya wrote:
+1
Thanks Matthias!
On Thu, 15 Apr 2021, 20:48 Israel Ekpo, wrote:
Makes perfect sense to me
+1 as well.
Thanks Matthias.
On Thu, Apr 15, 2021 at 2:41 PM Guozhang Wang wrote:
+1 as well
Thank you for the KIP, Jason!
+1 (binding)
Best,
Bruno
On 29.04.21 10:10, Luke Chen wrote:
Hi Jason,
+1 (non-binding)
Really need this KIP to save poor jenkins flaky tests. :)
Luke
On Thu, Apr 29, 2021 at 4:01 PM David Jacot
wrote:
+1 (binding)
Thanks for the KIP.
On Thu, Apr 29, 2021
Hi Josep,
Thank you for your interest in Apache Kafka.
I cannot find your user name neither in Jira nor in the wiki.
Did you register yourself in Jira and Confluence?
Best,
Bruno
On 04.05.21 14:29, Josep Prat wrote:
Hi,
I would like to start contributing to Apache Kafka, could you add my
us
registration process?
Best,
On Tue, May 4, 2021, 16:49 Josep Prat wrote:
Hi Bruno,
I just double checked now, and I'm logged in at https://issues.apache.org
and the username is josep.prat. I registered myself a couple of hours ago.
Thanks in advance,
On Tue, May 4, 2021, 15:34 Bruno Ca
Hi Matthew,
I granted you permissions to create a KIP.
Thank you for your interest in Apache Kafka.
Best,
Bruno
On 10.05.21 12:10, Matthew de Detrich wrote:
Wiki Id: mdedetrich-aiven
Hi Josep,
Thank for the PR!
Do not worry about the test failures. First of all, your PR does not
touch any code, so there is no reason a test would fail due to your PR.
Additionally, the failing tests are all known to be flaky. You can find
known flaky tests in the JIRA by searching for the t
e
KeyQuery
and
RangeQuery placeholders in the versioned store implementation as part
of
implementing your KIP:
https://github.com/apache/kafka/blob/f23394336a7741bf4eb23fcde951af0a23a69bd0/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredVersionedKeyValueStore.java#L142-
In my last e-mail I missed to finish a sentence.
"I think from a KIP"
should be
"I think the KIP looks good!"
On 9/6/23 1:59 PM, Bruno Cadonna wrote:
Hi Alieh,
Thanks for the KIP!
I think from a KIP
1.
I propose to throw an IllegalArgumentException or an
Illeg
Hi Alieh,
Thanks for the KIP!
I think from a KIP
1.
I propose to throw an IllegalArgumentException or an
IllegalStateException for meaningless combinations. In any case, the KIP
should specify what exception is thrown.
2.
Why does not specifying a range return the latest version? I would
e
Hi Alieh,
Thanks for the KIP!
One high level comment/question:
I assume you separated single key queries into two classes because
versioned key queries return a single value and multi version key
queries return iterators. Although, range queries always return
iterators, it would make sense t
s an error about the offsets column family not being opened, which
triggers a wipe and rebuild of the Task. Given that downgrades should be
uncommon, I think this is acceptable behaviour, as the end-state is
consistent, even if it results in an undesirable state restore.
Should I document the upgrade/dow
://github.com/adamretter/rocksjava-write-methods-benchmark#results
On Wed, 13 Sept 2023 at 09:41, Bruno Cadonna wrote:
Hi Nick,
Thanks for the updates and sorry for the delay on my side!
1.
Making the default implementation for flush() a no-op sounds good to me.
2.
I think what was bugging
since the last commit.
I realise this is getting into the weeds of the implementation, and
you'd
rather we focus 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 ev
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 validatio
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 the
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!
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 wo
ithin(fromTs, toTs)` (or maybe 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 sente
the current
agreement to 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 coul
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: Oskar
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
`
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.
+
2023 at 1:13 AM Matthias 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`-prefi
lation.level automatically switch
to READ_COMMITTED 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,
efault.state.isolation.level automatically
switch
to READ_COMMITTED 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
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 because the comment here:
https://github.com/apache/kafka/blob/c32d2338a7e0079e539b74eb16f0095380a1ce85/streams/src/main/java/org/
we can still enforce
coupling them.
Again, just my 2c here. Thanks again for the great patience and
diligence on this KIP.
Guozhang
On 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 c
I
believe 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`?
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
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 great
implementation (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
implementatio
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 downgrad
301 - 400 of 678 matches
Mail list logo
