a*
Carmes / Bâtiment A17 4e / 63100 Clermont-Ferrand
--------
*De :* Bruno Cadonna
*Envoyé :* mercredi 10 avril 2024 10:38
*À :* dev@kafka.apache.org
*Objet :* [EXT] Re: [DISCUSS] KIP-1033: Add Kafka Streams exception
handler for exceptions occuring during processing
Warnin
Congratulations, Greg!
Best,
Bruno
On 4/15/24 7:33 AM, Claude Warren wrote:
Congrats Greg! All the hard work paid off.
On Mon, Apr 15, 2024 at 6:58 AM Ivan Yurchenko wrote:
Congrats Greg!
On Sun, Apr 14, 2024, at 22:51, Sophie Blee-Goldman wrote:
Congrats Greg! Happy to have you
On Sun,
creating temporary StateManagers and StateStores during rebalance.
I
think
it is possible, and probably not too expensive, but the devil will
be
in
the detail.
I'll try to find some time to explore the idea to see if it's
possible
and
report back, because we'll need to
Hi,
sorry, I am late to the party.
I have a couple of comments:
(1)
I would prefer Client* instead of Node* in the names. In Kafka Streams
we do not really have the concept of node but we have the concept of
client (admittedly, we sometimes also use instance). I would like to
avoid introduci
added during the initial
KIP discussion so that's probably why it doesn't follow the same naming
pattern. Personally I'm fine either way (I do think ApplicationMetadata
sounds a bit better but that's not a good enough reason :P)
Thanks Bruno!
On Wed, Apr 17, 2024 at 7:08 AM Brun
should consider
the interface approach afterwards, though.
Best,
Bruno
On 4/17/24 3:15 PM, Bruno Cadonna wrote:
Hi Nick and Sophie,
I think the task ID is not enough to create a state store that can read
the offsets of non-assigned tasks for lag computation during
rebalancing. The state
is used by
the other handlers, I do think it makes sense to leverage it instead
of creating a new metric.
I will update the KIP to update the dropped-record-metric.
8. Regarding the DSL, I am aligned with Bruno, I think we could close
the gaps in a future KIP.
Cheers,
Damien
On Thu, 11 Ap
Congrats!
Best,
Bruno
Am 25. April 2024 05:18:19 MESZ schrieb Yash Mayya :
>Congratulations Igor!
>
>On Wed, 24 Apr, 2024, 23:36 Colin McCabe, wrote:
>
>> Hi all,
>>
>> The PMC of Apache Kafka is pleased to announce a new Kafka committer, Igor
>> Soarez.
>>
>> Igor has been a Kafka contributor s
is mean that an assignment gives the same set of
partition
indices for
all topics
which happen to match the regex? So, a subtopology
reading
from
A*
that
matches
AB and AC would give the same set of partitions to
each
task for
both
topics, and
is not able to give AB:0 to one task and A
be documented, but I guess it's safe
to push the responsibility of the DLQ records to the user if they
implement custom handlers.
Cheers,
Damien
On Tue, 11 Jun 2024 at 17:00, Bruno Cadonna wrote:
Hi,
since there was not too much activity in this thread recently, I was
wondering what the
Well deserved!
Best,
Bruno
On 8/28/24 6:37 PM, Bill Bejeck wrote:
Congrats Lianet!
On Wed, Aug 28, 2024 at 12:32 PM Matthias J. Sax wrote:
Congrats! Very well deserved!
On 8/28/24 9:18 AM, Justine Olshan wrote:
Congratulations Lianet!!
Justine
On Wed, Aug 28, 2024 at 8:58 AM David Arthur
Hi all,
For your info, I updated the StreamsGroupInitialize request with the
following changes:
1. I added the topology ID to the request so that the group coordinator
knows for which topology it got the initialization.
2. I renamed field "Subtopology" to "SubtopologyId" since the field is
Hi all,
For your info, I updated the StreamsGroupInitialize request with the
following changes:
1. I added the topology ID to the request so that the group coordinator
knows for which topology it got the initialization.
2. I renamed field "Subtopology" to "SubtopologyId" since the field is
this KIP.
Cheers,
Damien Sebastien and Loic
On Tue, 27 Aug 2024 at 15:37, Sebastien Viale
wrote:
Hi Bruno,
We have planned a meeting for next friday to discuss it with Loic and Damien.
We will be able to restart discussions about it soon.
regards
________
De : B
What do
you think?
Cheers,
Damien
On Tue, 3 Sept 2024 at 14:59, Bruno Cadonna wrote:
Hi,
Thanks for the updates!
I have a couple of comments.
BC1
Do you also plan to add an argument to the StreamsResetter tool to
delete the default DLQ topic when a Streams app is reset?
BC2
Hi Colin,
Unfortunately, we found a bug in Kafka Streams yesterday that make
operating a Kafka Streams application challenging.
The bug is described in the following ticket:
https://issues.apache.org/jira/browse/KAFKA-17489
The bug happens when task fail due to consumption issues like
Offs
Congrats, Josep!
Best,
Bruno
On 9/7/24 12:15 AM, Viktor Somogyi-Vass wrote:
Congrats Kosep!
On Fri, Sep 6, 2024, 23:46 David Arthur wrote:
Congrats, Josep! Very well deserved!
-David
On Fri, Sep 6, 2024 at 2:36 PM Kirk True
wrote:
Congratulations Josep!
On Fri, Sep 6, 2024 at 11:06
(Guozhang, Bill, Matthias voted on the DISCUSS thread).
> >> > non-binding +1: 2 (Bruno, John).
> >> >
> >> >
> >> > Guozhang
> >> >
> >> >
> >> > On Thu, Aug 22, 2019 at 8:16 AM Bill Bejeck wrote:
> >>
Hi Nagendra,
What you describe is a known issue:
https://issues.apache.org/jira/browse/KAFKA-9675
And you also described the appropriate fix:
https://github.com/apache/kafka/pull/8256
The issue is fixed and will be included in 2.6.0, 2.4.2, 2.5.1.
I am sorry for any inconveniences.
Best,
Bruno
Hi Guozhang,
Thank you for the KIP!
Exposing also the inner types of the wrapper serdes would be
important. For debugging as Matthias has already mentioned and to see
more easily changes that are applied to a topology.
I am also +1 on the `toJson()` method to easily access the topology
descripti
Hi all,
I'd like to discuss KIP-607 that aims to add RocksDB memory usage
metrics to Kafka Streams.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-607%3A+Add+Metrics+to+Record+the+Memory+Used+by+RocksDB+to+Kafka+Streams
Best,
Bruno
o know in advance if/how we can
> get the information about inner serdes. I am not sure atm if we would
> need more API changes to get this info. The other (minor) question is
> also, how this information would be presented to the use (as we only use
> `String` types for Serde information.
&
ty strongly in
> favor of reporting these
> at the store level.
>
> Best,
> Sophie
>
> On Wed, May 6, 2020 at 8:41 AM Bruno Cadonna wrote:
>
> > Hi all,
> >
> > I'd like to discuss KIP-607 that aims to add RocksDB memory usage
> > metrics to
he entire process, in which case
> > the memory usage
> > metric for any one store should reflect the memory usage of the entire
> > instance. In that case
> > any effort to roll up the memory usages ourselves would just be wasted.
> >
> > Sorry for the rever
orth considering that some users may be using the bounded
> > > memory
> > > config setter
> > > to put a cap on the off-heap memory of the entire process, in which case
> > > the memory usage
> > > metric for any one store should reflect the memo
Hi Sophie,
Thank you for the KIP.
The KIP looks good to me.
50th percentile:
I think we do not need it now. If we need it, we can add it. Here the
old truism applies: Adding is always easier than removing.
processor-node-level metrics:
I think it is good to have the staleness metrics also on
pr
Hi Matthias,
Thank you for the KIP. I like your KIP.
Here my feedback:
1. The KIP is not clear about what should happen when task.timeout.ms
expires. To facilitate the mapping from the error users might
encounter due to timeouts to this KIP, it would be good to state the
error that will be throw
Hi all,
I'd like to call for votes on
KIP-607: Add Metrics to Record the Memory Used by RocksDB to Kafka Streams
The KIP can be found here
https://cwiki.apache.org/confluence/display/KAFKA/KIP-607%3A+Add+Metrics+to+Kafka+Streams+to+Record+the+Memory+Used+by+RocksDB
The discussion thread can be
Hi Matthias,
I am +1 (non-binding) on the KIP.
Just one final remark: Wouldn't it be better to specify
task.timeout.ms to -1 if no retry should be done? IMO it would make
the config more intuitive because 0 would not have two possible
meanings (i.e. try once and never try) anymore.
Best,
Bruno
; > > > > > > > > point of
> > > > > > > > > > > >> view.
> > > > > > > > > > > >>
> > > > > > > > > > > >> Regarding your second. point, I'm inclined to leave
> > that
> >
;>> Thanks for the KIP!
> >>>
> >>> +1 (binding)
> >>>
> >>> -Bill
> >>>
> >>> On Fri, May 15, 2020 at 11:12 AM Guozhang Wang wrote:
> >>>
> >>>> +1.
> >>>>
> >>&g
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 cod
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 be
ists.
Cheers,
Chris
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
t
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 Eg
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
y.
On Tue, Aug 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
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 not
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 se
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
outsi
uot;, and change all other metrics' "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: ye
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 mo
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
+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.
Chee
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 100
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: sneha
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 p
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 wro
Thank you all!
I am really honoured to have become a PMC member.
Looking forward to contributing further to Apache Kafka.
Best,
Bruno
On 02.11.22 17:02, Levani Kokhreidze wrote:
Congrats Bruno, well deserved!
On Wed, 2 Nov 2022, 11:11 Jorge Esteban Quilcate Otoya, <
quilcate.jo...@gmail.com>
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 not
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é
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 t
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, 2,
not
will cause any weird issues. If no, maybe just expose a metric for
autoscaling state, and have a state said "failed" 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
led 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 Wed, Nov 23, 2022 at 8:52 AM Bruno Cadonna wrote:
Hi all,
Thanks for
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 to
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 w
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!
opic configs and collecting validation
errors
(
https://github.com/apache/kafka/blob/be032735b39360df1a6de1a7feea8b4336e5bcc0/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java#L318-L319
)
but this method is not called from anywhere, even though the
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 a
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 Ch
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 Duggan
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:
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:
Congrat
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
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 test
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 it
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!
One quest
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 followin
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, 2023
Thanks, Mickael!
Best,
Bruno
On 09.02.23 03:15, Luke Chen wrote:
Hi Mickael,
Thanks for volunteering!
Luke
On Thu, Feb 9, 2023 at 6:23 AM Chris Egerton
wrote:
Thanks for volunteering, Mickael!
On Wed, Feb 8, 2023 at 1:12 PM José Armando García Sancio
wrote:
Thanks for volunteering Mick
Hi,
ClientMetricsTest.shouldAddCommitIdMetric should only fail if executed
from an IDE. The test fails because the test expects a file on the
class path which is not there when the test is executed from the IDE,
but is there when the test is executed from gradle. I will try to fix
the test so that
Hi Vahid and Eric,
Thank you for your input.
I suppose you both used the archive of the release candidate and did
not checkout the tag from the git repository.
I found the issue. The archive misses the .git directory that is
needed for the unit test to pass.
Opened the following PR to fix it: h
eedback.
>
> On Mon, Nov 18, 2019 at 12:24 PM Bruno Cadonna wrote:
>>
>> Hi Vahid and Eric,
>>
>> Thank you for your input.
>>
>> I suppose you both used the archive of the release candidate and did
>> not checkout the tag from the git repository.
>
Hi,
I tried with "Retest this, please" but it didn't work.
Best,
Bruno
On Tue, Jan 14, 2020 at 9:01 AM Levani Kokhreidze
wrote:
>
> Hello,
>
> Seems like there’re issues with triggering Jenkins builds. Latest commits for
> my PR doesn’t trigger any of the builds.
> Any ideas how to fix the iss
Hi Deepak,
Subscription to the mailing lists is self service. See
https://kafka.apache.org/contact
Best,
Bruno
On Tue, Jan 21, 2020 at 8:35 AM Deepak Goyal wrote:
>
> Hi,
>
> Can you please add me to the dev mailing list
>
> --
> Deepak Goyal (+919502447100)
Hi Navinder,
Thank you for the KIP!
It looks good to me. Here my comments:
1) I agree with John and Matthias that you should remove the
implementation of the methods in the KIP. Just the method signatures
suffice and make the reading easier.
2) According to the grammar `withIncludeStaleStores()
iable staleStores. Since anyways we
> > are not using constructor, so the only way the variable is exposed
> > outside is the getter and the optional builder method. With this
> > variable name, we can name the builder method as "enableStaleStores"
> > and I feel
Hi Navinder,
+1 (non-binding)
Best,
Bruno
On Thu, Jan 23, 2020 at 9:19 AM John Roesler wrote:
>
> Thanks, Navinder. It's just to give everyone a chance to object if they
> wanted to.
> -John
>
> On Thu, Jan 23, 2020, at 00:44, Navinder Brar wrote:
> > Oh sorry, my bad. Will wait for another 12
Hi Richard,
Thank you for the KIP.
I agree with John that we should focus on the interface and behavior
change in a KIP. We can discuss the implementation later.
I am also +1 for the survey.
I had a thought about this. Couldn't we consider emit-on-change to be
one config of suppress (like `unti
; perfectly fine without the opt-out config. I
> > really think that (because of the timestamp
> > semantics work already underway), we're already
> > pre-fetching the prior result most of the time, so
> > there would actually be very little extra I/O
> > involve
> > >>>> Hello to all,
> > >>>>
> > >>>> I've finished making some initial modifications to the KIP.
> > >>>> I have decided to keep the implementation section in the KIP for
> > >>>> record-keeping purpose
I guess you can think of this rule as more of a style guide than a
> grammar, but whatever. As a maintainer, I think we should discourage
> these particular classes to have different instance variables than
> method names. Otherwise, it's just silly. Either "includeStaleStore
Thanks!
+1 (non-binding)
Best,
Bruno
On Fri, Feb 14, 2020 at 1:57 AM Boyang Chen wrote:
>
> +1 (non-binding)
>
> On Thu, Feb 13, 2020 at 4:45 PM Guozhang Wang wrote:
>
> > +1 (binding).
> >
> >
> > Guozhang
> >
> > On Tue, Feb 11, 2020 at 5:29 PM Guozhang Wang wrote:
> >
> > > Hi Sophie,
> >
>>> my example have names or topics or any other identifiable
> > > >>>>>>>>>> characteristic that could be passed to a ChangeDetector class
> > > >>>>>>>>>> registered via config. You could say that we
s depending on equals() or adding a ChangeDetector interface, then
> we should consider adding a configuration as part of that future work. In
> fact, if we add a simple "opt-in/opt-out" switch right now, we might find
> that it's actually insufficient for whatever future feature
.
> > > >>
> > > >> If there isn't anything else, I will probably start the voting process
> > > >> next week!
> > > >>
> > > >> Cheers,
> > > >> Richard
> > > >>
> > > >>
&
Congrats, Konstantine! Excellent!
Best,
Bruno
On Thu, Feb 27, 2020 at 11:28 AM Rajini Sivaram wrote:
>
> Congratulations Konstantine!
>
> On Thu, Feb 27, 2020 at 9:57 AM Mickael Maison
> wrote:
>
> > Congratulations Konstantine! Well deserved
> >
> > On Thu, Feb 27, 2020 at 7:11 AM Satish Dugga
streamline the KIP document as much as
> possible. Keeping a "discarded" section in the document will just make it
> harder for new people to understand the proposal. We did the same thing
> with KIP-441, where there were two prior drafts included at the end of the
> document, and
Hi Richard,
+1 (non-binding)
Best,
Bruno
On Mon, Mar 2, 2020 at 4:33 PM John Roesler wrote:
>
> Hi Richard,
>
> Thanks for the KIP!
>
> I'm +1 (binding)
>
> -john
>
> On Thu, Feb 27, 2020, at 14:40, Richard Yu wrote:
> > Hi all,
> >
> > I am proposing a new optimization to Kafka Streams which w
Thanks for the votes so far!
> > @Matthias or @Guozhang Wang it would be great to
> > also get your input on this KIP.
> >
> > It looks to be pretty close to completion, so the finishing touches are all
> > we need. :)
> >
> > Best,
> > Richard
> >
557. I.e.,
> > > KIP-557 neither makes that bug worse or better.
> > >
> > > One other thought I had is maybe you were thinking that operators
> > > would update their internally tracked stream time, but still discard
> > > records? I think that _would_ be a bu
Hi David,
A bug report was filed that can be considered a blocker. Basically,
with this bug all RocksDB metrics reported by Streams are constant
zero. The bug is there since 2.4., so it is not a regression, but a
broken feature.
Here is the ticket: https://issues.apache.org/jira/browse/KAFKA-9675
#x27;t
> think it qualifies as a blocker for 2.5.0.
>
> Ismael
>
> On Mon, Mar 9, 2020 at 8:44 PM Bruno Cadonna wrote:
>
> > Hi David,
> >
> > A bug report was filed that can be considered a blocker. Basically,
> > with this bug all RocksDB metrics reported by Str
able to focus on this again.
Regards,
Nick Telford
On Wed, 22 Dec 2021 at 09:28, Bruno Cadonna wrote:
Hi Nick,
Thanks for the updates!
The motivation section and the description of the new config is much
clearer and informative now!
You missed one "delete.interval.ms" in the last
the specification.
If there are no other issues, I'll put this to a vote.
Regards,
Nick Telford
On Tue, 11 Jan 2022 at 15:34, Bruno Cadonna wrote:
Hi Nick,
Sorry for the delay!
Regarding point 7, I am fine with keeping the config as an interval and
keeping it independently of the
mmit.interval.ms
(3).
It seems unnecessary to me.
-Matthias
On 1/12/22 7:21 AM, Nick Telford wrote:
Thanks Bruno, I've made those changes.
I'll call a vote on the KIP later today.
Regards,
Nick Telford
On Wed, 12 Jan 2022 at 12:13, Bruno Cadonna wrote:
Hi Nick,
Great!
Hi Nick,
Since the title of the KIP slightly changed after the vote was opened
also the link to the KIP changed as a result. This is should be a
working link:
https://cwiki.apache.org/confluence/x/JY-kCw
Anyways, Thanks for the KIP!
I am +1 (binding)
Best,
Bruno
On 12.01.22 16:34, Nick
Hi Phil,
the contributors list is independent from the mailing list.
Unsubscribing from the mailing list is self-service. See
https://kafka.apache.org/contact for instructions to unsubscribe.
Hope that helps!
Best,
Bruno
On 16.01.22 16:12, Philippe Derome wrote:
Please remove me from the c
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.
T
201 - 300 of 686 matches
Mail list logo
