Note: we have alot of KStream service deployed (similar function,
different sources) so the resource kind of restricted.
Thank you!
Martinus Elvin
On 1/18/2025 3:24 AM, Matthias J. Sax wrote:
Hi,
In general, we recommend one StreamThread per core, so 48 threads
sounds excessive; I don
Hi,
In general, we recommend one StreamThread per core, so 48 threads sounds
excessive; I don't think that a single pod would get 48 cores? So using
more pods with fewer threads each, might be a first good step.
The only config that sticks out is
> - max.poll.records = 1
Not sure why you re
Thanks for reaching out. Can you file a Jira ticket to report this as a
bug? Hard to say if this could be a broker or producer bug...
Did you try newer clients / broker version? Can you reproduce this with
latest 3.9.0 release?
-Matthias
On 1/17/25 11:31 AM, Donny Nadolny wrote:
We're exper
Hi,
This project is currently on hold, as nobody has time to work on it.
The newly added "state updater" thread was completed and is enabled
since AK 3.8 release already. (You might have noticed the corresponding
ticket on the wiki page, which are already resolved.)
There was some work done
This older email was just brought to my attention.
I did look into it, and it is indeed a bug:
https://issues.apache.org/jira/browse/KAFKA-18478
The workaround should be to set the StreamsConfig value serde to the
stream-side value serde to make it work.
-Matthias
On 4/8/24 10:30 PM, Mic
3.7.2 was release today.
On 12/13/24 12:14 AM, Josep Prat wrote:
Hi Sahil,
These are the Apache Kafka versions where commons-io has been updated to a
version not vulnerable to CVE-2024-47554:
- 3.9.0
- 3.8.1
- Upcoming 3.7.2
- Upcoming 4.0.0
Best,
On Fri, Dec 13, 2024 at 6:46 AM Sahil Sharma
, Igor
Soarez, Josep Prat, Ken Huang, Kirk True, Kondrat Bertalan, Kuan-Po
Tseng, Laxman Ch, Lianet Magrans, Luke Chen, Manikumar Reddy, Matthias
J. Sax, Mickael Maison, Omnia Ibrahim, PoAn Yang, Rohan, TengYao Chi,
Vedarth Sharma, Vikas Singh
We welcome your help and feedback. For more
This vote passes with 8 +1 votes (4 bindings) and no 0 or -1 votes.
+1 votes
PMC Members:
* Bill Bejeck
* Divij Vaidya
* Luke Chen
* Matthias J. Sax
Committers:
* Andrew Schofield
Community:
* Jiunn-Yang
* TengYao
* Federico Valeri
0 votes
* No votes
-1 votes
* No votes
Vote thread:
https
a_2.13-3.7.2.tgz
- Ran basic quickstart using 3.7.2-rc1 docker image
+1 binding from me.
Thanks.
Luke
On Fri, Dec 6, 2024 at 12:06 PM Matthias J. Sax
wrote:
Thanks Josep. Great idea.
Here is the draft PR link for docs updates:
https://github.com/apache/kafka-site/pull/652
Thanks Div
d, Dec 4, 2024 at 3:15 PM Matthias J. Sax
wrote:
Hello Kafka users, developers and client-developers,
This is the second candidate for release of Apache Kafka 3.7.2. This
is
a bug-fix release, closing 21 Jira tickets.
Release notes for the 3.7.2 release:
https://dist.apache.org/repos
eams quickstart
When I looked over the documentation, I noticed the quickstart (main page
and Kafka Streams) still reference the previous release 3.7.1, but this
isn't enough to block the release, we can do a PR against the kafka-site
repo.
+1(binding)
Regards,
Bill
On Wed, Dec 4, 2024 at 3:1
Hello Kafka users, developers and client-developers,
This is the second candidate for release of Apache Kafka 3.7.2. This is
a bug-fix release, closing 21 Jira tickets.
Release notes for the 3.7.2 release:
https://dist.apache.org/repos/dist/dev/kafka/3.7.2-rc1/RELEASE_NOTES.html
Please dow
Hi,
I just wanted to give a status update on 3.7.2 release. While working on
RC0, we found a CVE that needs to be fixed (already fixed in trunk, 3.9,
and 3.8, so I just need to cherry-pick the commit).
However, some artifacts for RC0 got already published while preparing
the RC, thus we need
Congrats!
On 12/2/24 12:02 PM, Kirk True wrote:
Congratulations Andrew Well-deserved.
On Mon, Dec 2, 2024, at 6:13 AM, David Arthur wrote:
The Project Management Committee (PMC) for Apache Kafka is pleased to
announce Andrew Schofield as a new Kafka committer.
Andrew has been active in th
will be in binary right,
so the fetched data in binary message is upto "Lorem ipsum dolor sit amet,
consectetur adipiscing elit, sed do " for example
Then how data is assembled together for remaining potion ? how data is made as
whole ?
____________
From:
1. As pointed out in the JavaDocs
@param timeoutMs The time, in milliseconds, spent waiting in poll if data is
not available in the buffer.
2. If there is no data with the timeout, `poll()` return an "empty"
`ConsumerRecords` object.
For error/exception I cannot say, as it depends on the
You should be all set.
On 9/13/24 7:47 PM, 最红 wrote:
Hi,
I'd like to apply for a jira id to contribute to Kafka.
Jira ID: veryfirefly
Thank you
fixed yet. There is
a PR from March '24. This bug seems urgent to me. Are there any plans about
merging the PR?
-Kevin
-Ursprüngliche Nachricht-
Von: Matthias J. Sax
Gesendet: Freitag, 30. August 2024 04:19
An: users@kafka.apache.org
Betreff: Re: Unexpected Tombstone records a
Sounds like https://issues.apache.org/jira/browse/KAFKA-16394
-Matthias
On 8/29/24 02:35, Vogel, Kevin, DP EPS, BN, extern, external wrote:
Hello there,
I searched the Apache Jira for a bug report on this topic but couldn't find
one. Maybe anyone else has noticed something similar or knows mo
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 wrote:
Congrats, Lianet!
On Wed, Aug 28, 2024 at 11:48 AM Mickael Maison
wrote:
Congratulations Lianet!
On Wed, Aug 28, 2024 at 5:40 PM J
Is there a way for our producer to fail quickly if not available?
No. Client will just try to re-connect internally. They don't rise any
error if they disconnect.
On 8/22/24 5:45 AM, Keith Brown wrote:
Sometimes out is unavailable. Our producer gives this error
[kafka-producer-network-th
I don't think there is any example, but seems to be more or less
"straightforward" to do?
However, I am wondering about the usage pattern? Does not sound like a
good fit for Kafka. Producers and consumer should be long lived. It's an
anti pattern to use short lived clients (Kafka is optimized
What do you mean by "timeout a consumer"?
Given that a consumer calls `poll()` and `poll()` might also return with
no data, the consumer code is in full control anyway...
I want to make sure
a certain message gets pushed if not then exit.
This sounds like writing. How it it related to a co
Not 100% sure if librdkafka provides the exact some semantics as the
Kafka Java producer (but I believe it does for this case; but might be
worth to check the docs?).
If `send()` gives an error back, ordering would not be guaranteed any
longer if the retry happens at the application level. Ord
It's not in our control. The INFRA team needs to create accounts
manually at this point, and we don't know at what cadence they find time
to do this. Sorry :(
If an account is create, I believe you should get an email.
We know that this current workaround is very tedious, but there is
unfortu
In the end you create a new consumer group. That's totally fine.
The old consumer group will still "exist", ie, the committed offsets for
the group are still there, until they will be eventually purged by the
brokers (I think the default is 7 days to keep the metadata of consumer
groups, after
Jenny,
thanks for reaching out. Yes, we plan to remove the old variant of
`branch()` (which was deprecated with KIP-418) in the 4.0 release
(https://issues.apache.org/jira/browse/KAFKA-12824) which is planned for
end of this year.
KIP-418 changes the pattern from relying on order to relying
Follow instruction from the webpage: https://kafka.apache.org/contact
On 6/4/24 9:01 AM, outof2...@sina.com wrote:
I want to subscribe
Mailing list subscription is self-service. Please follow the instruction
from the web-page: https://kafka.apache.org/contact
-Matthias
On 5/21/24 2:00 AM, Prashant Lohia wrote:
thanks
prashant lohia
prash...@gsl.in
ces of the application will
process records? For example, if the input topics each have 6 partitions,
and I use the repartition method to set the number of partitions for the
streams to 2, how many instances of the application will process records?
Thanks,
Chad
On Wed, May 1, 2024 at 6:47 PM Matth
_______
From: Matthias J. Sax
Sent: Saturday, May 18, 2024 4:06
To: users@kafka.apache.org
Subject: Re: 回复: Request to be added to kafka contributors list
Did you sign out and sign in again?
On 5/17/24 9:49 AM, Yang Fan wrote:
Thanks Matthias,
I still can't find "Assign to me"
Done. You should be all set :)
-Matthias
On 5/20/24 10:10 AM, bou...@ulukai.net wrote:
Dear Apache Kafka Team,
I hope to post in the right place: my name is Franck LEDAY, under
Apache-Jira ID "handfreezer".
I opened an issue as Improvement KAFKA-16707 but I failed to
assigned i
What is your Jira ID?
-Matthias
On 5/20/24 9:55 AM, Brenden Deluna wrote:
Hello, I am requesting to be added to the contributor list to take care of
some tickets. Thank you.
Zookeeper is already deprecated (since 3.5):
https://kafka.apache.org/documentation/#zk_depr
It's planned to be fully removed in 4.0 release.
It's not confirmed yet, but there is a high probability that there won't
be a 3.9 release, and that 4.0 will follow 3.8.
-Matthias
On 5/20/24 2:11
Did you sign out and sign in again?
On 5/17/24 9:49 AM, Yang Fan wrote:
Thanks Matthias,
I still can't find "Assign to me" button beside Assignee and Reporter. Could
you help me set it again?
Best regards,
Fan
____
发件人: Matthias J. Sax
发送时间: 2024
Hello Kay,
What you describe is "by design" -- unfortunately.
The problem is, that when we build the `Topology` we don't know the
partition count of the input topics, and thus, StreamsBuilder cannot
insert a repartition topic for this case (we always assume that the
partition count is the sam
Thanks for reaching out Yang. You should be all set.
-Matthias
On 5/16/24 7:40 AM, Yang Fan wrote:
Dear Apache Kafka Team,
I hope this email finds you well. My name is Fan Yang, JIRA ID is fanyan, I
kindly request to be added to the contributors list for Apache Kafka. Being
part of this list
If I read this correctly, your upstream producer which writes into the
input topic of you KS app is using a custom partitioner?
If you do a `groupByKey()` and change the key upstream, it would result
in a repartition step, which would fall back to the default partioner.
If you want to use a c
76cf0-3910-4c25-bfad-ea2b98953db3-StreamThread-9
Message: [Consumer
clientId=kafka-streams-exec-0-test-store-6d676cf0-3910-4c25-bfad-ea2b98953db3-StreamThread-9-consumer,
groupId=kafka-streams-exec-0-test-store ] Node 102 disconnected.
On Mon, Apr 22, 2024 at 7:16 AM Matthias J. Sax wrote:
ogs and the stream does process one sided joins after the
skipped record. Do you have any docs on the "dropper records" metric? I did
a Google search and didn't find many good results for that.
Thanks,
Chad
On Tue, Apr 30, 2024 at 2:49 PM Matthias J. Sax wrote:
Thanks for the i
I can hone in on to tell me what is going on?
Basically, I'm looking for some pointers on where I can start looking.
Thanks,
Chad
On Tue, Apr 30, 2024 at 10:26 AM Matthias J. Sax wrote:
I expect the join to
execute after the 25 with one side of the join containing a record and
the
oth
I expect the join to
execute after the 25 with one side of the join containing a record and the
other being null
Given that you also have a grace period of 5 minutes, the result will
only be emitted after the grace-period passed and the window is closed
(not when window end time is reached).
Did you look into .windowedBy(...).emitStrategy(...) ?
Using emit-final you would get an downstream even only after the window
closed.
-Matthias
On 4/29/24 1:43 AM, Santhoshi Mekala wrote:
Hi Team,
We have the below requirement:
We are processing batch logs in kstreams. Currently, we are st
Congrats!
On 4/24/24 2:29 PM, Bill Bejeck wrote:
Congrats Igor!
-Bill
On Wed, Apr 24, 2024 at 2:37 PM Tom Bentley wrote:
Congratulations Igor!
On Thu, 25 Apr 2024 at 6:27 AM, Chia-Ping Tsai wrote:
Congratulations, Igor! you are one of the best Kafka developers!!!
Mickael Maison 於 2024
Not sure either, but it sounds like a bug to me. Can you reproduce this
reliably? What version are you using?
It would be best if you could file a Jira ticket and we can take it from
there.
-Matthias
On 4/21/24 5:38 PM, Penumarthi Durga Prasad Chowdary wrote:
Hi ,
I have an issue in kafka-
The main difference is the internal implementation. Semantically, both
are equivalent.
suppress() uses an in-memory buffer, while `emitStrategy()` does not,
but modifies the upstream aggregation operator impl, and waits to send
results downstream, and thus, it's RocksDB based.
-Matthias
O
I don't think that there is any specific recommendation. However, there
is an overall max-message-size config that you need to keep in mind.
-Matthias
On 4/16/24 9:42 AM, Gabriel Giussi wrote:
I have logic in my service to capture exceptions being thrown during
message processing and produce a
Congrats Greg!
On 4/15/24 10:44 AM, Hector Geraldino (BLOOMBERG/ 919 3RD A) wrote:
Congrats! Well deserved
From: d...@kafka.apache.org At: 04/13/24 14:42:22 UTC-4:00To:
d...@kafka.apache.org
Subject: [ANNOUNCE] New Kafka PMC Member: Greg Harris
Hi all,
Greg Harris has been a Kafka committer
Perf tuning is always tricky... 350 rec/sec sounds pretty low though.
You would first need to figure out where the bottleneck is. Kafka
Streams exposes all kind of metrics:
https://kafka.apache.org/documentation/#kafka_streams_monitoring
Might be good to inspect them as a first step -- maybe
Yeah, that is some quirk of KS runtime...
There is some internal config (for perf reasons) that delays emitting
results... An alternative to advancing wall-clock time would be to set
this internal config to zero, to disable the delay.
Maybe we should disable this config when topology test dri
nce group in state
PreparingRebalance with old generation (__consumer_offsets-nn) (reason: Updating
metadata for member during Stable; client reason: need to revoke partitions
and re-join) (kafka.coordinator.group.GroupCoordinator)
I am guessing that the two are unrelated. If you have any
Congrats!
On 3/26/24 9:39 PM, Christo Lolov wrote:
Thank you everyone!
It wouldn't have been possible without quite a lot of reviews and extremely
helpful inputs from you and the rest of the community! I am looking forward
to working more closely with you going forward :)
On Tue, 26 Mar 2024 a
Without detailed logs (maybe even DEBUG) hard to say.
But from what you describe, it could be a metadata issue? Why are you
setting
METADATA_MAX_AGE_CONFIG (consumer and producer): 5 hours in millis (to make
rebalances rare)
Refreshing metadata has nothing to do with rebalances, and a meta
To subscribe, please follow instructions from the webpage
https://kafka.apache.org/contact
-Matthias
On 2/23/24 1:15 AM, kashi mori wrote:
Hi, please add my email to the mailin list
Filed https://issues.apache.org/jira/browse/KAFKA-16295
Also, for global store support, we do have a ticket already:
https://issues.apache.org/jira/browse/KAFKA-13523
It's actually a little bit more involved due to position tracking... I
guess we might need a KIP to fix this.
And yes: if an
https://cwiki.apache.org/confluence/display/KAFKA/Time+Based+Release+Plan#TimeBasedReleasePlan-WhatIsOurEOLPolicy?
On 2/11/24 8:08 PM, Sahil Sharma D wrote:
Hi team,
Can you please share the EOS date for Kafka Version 3.5.1?
Regards,
Sahil
in order to build an aggregate person. There
are 14 sub topologies... - measuring the e2e latency shows values
around 600ms which seems rather high to me. Does that sound crazy? ;)
Best wishes
Karsten
Am Do., 1. Feb. 2024 um 19:02 Uhr schrieb Matthias J. Sax :
I see. You need to ensure that you get
hen
using that for three independent re-key-operations is not allowed.
Best wishes,
Karsten
Am Do., 1. Feb. 2024 um 02:16 Uhr schrieb Matthias J. Sax :
Thanks for the details. This does make sense.
So it seems you can read all topic as table (ie, builder.table("topic")
-- no need to
is 1 as per Kafka UI, as I've specified no extra configuration
for them.
Best wishes,
Karsten
Am Di., 30. Jan. 2024 um 20:03 Uhr schrieb Matthias J. Sax :
Both fk1 and fk2 point to the PK of another entity (not shown for
brevity, of no relevance to the question).
It this two independent FK, or
Did reply on SO.
-Matthias
On 1/24/24 2:18 AM, warrior2...@gmail.com wrote:
Let's say there's a topic in which chunks of different files are all
mixed up represented by a tuple |(FileId, Chunk)|.
Chunks of a same file also can be a little out of order.
The task is to aggregate all files and
Both fk1 and fk2 point to the PK of another entity (not shown for
brevity, of no relevance to the question).
It this two independent FK, or one two-column FK?
Ingesting the topic into a Kafka Streams application, how can I re-key
the resulting KTable by both fk1 and fk2?
If you read the top
ped stream here ???/*
On 2024-Jan-13 01:22, Matthias J. Sax wrote:
`KGroupedStream` is just an "intermediate representation" to get a
better flow in the DSL. It's not a "top level" abstraction like
KStream/KTable.
For `KTable` there is `transformValue()` -- there is
François,
thanks for starting this initiative. Personally, I don't think it's
necessarily harmful for the project to add such a new page, however, I
share the same concerns others raised already.
I understand your motivation that people had issues finding commercial
support, but I am not sur
`KGroupedStream` is just an "intermediate representation" to get a
better flow in the DSL. It's not a "top level" abstraction like
KStream/KTable.
For `KTable` there is `transformValue()` -- there is no `transform()`
because keying must be preserved -- if you want to change the keying you
ne
the Kafka broker logs? I do not see any other
errors logs on the client / application side.
On Fri, 29 Sep, 2023, 22:01 Matthias J. Sax, wrote:
In general, Kafka Streams should keep running.
Can you inspect the logs to figure out why it's going into ERROR state
to begin with? Maybe you ne
In general, Kafka Streams should keep running.
Can you inspect the logs to figure out why it's going into ERROR state
to begin with? Maybe you need to increase/change some timeouts/retries
configs.
The stack trace you shared, is a symptom, but not the root cause.
-Matthias
On 9/21/23 12:56
For the config you provide, data loss should not happen (as long as you
don't allow for unclean leader election, which is disabled by default).
But you might be subject to unavailability for some partitions if a
broker fails.
-Matthias
On 9/17/23 7:49 AM, 陈近南 wrote:
Hello,
Can a me
t is the case with topics that were consumed previously and
not
consumed now.
Does creation of new consumer group (setting a different application.id)
on
streams application an option here?
On Thu, Aug 17, 2023 at 7:03 AM Matthias J. Sax
wrote:
Well, it's kinda expected behavior. I
Your update to the KTable is async when you send data back to the KTable
input topic. So your program is subject to race-conditions.
So switching to the PAPI was the right move: it make the update to the
state store sync and thus fixes the issue.
-Matthias
On 9/4/23 5:53 AM, Mauricio Lopez
e inactive consumer group is cleared up after 7 days however not
sure if that is the case with topics that were consumed previously and not
consumed now.
Does creation of new consumer group (setting a different application.id) on
streams application an option here?
On Thu, Aug 17, 2023 at 7:03 AM
Well, it's kinda expected behavior. It's a split brain problem.
In the end, you use the same `application.id / group.id` and thus the
committed offsets for the removed topics are still in
`__consumer_offsets` topics and associated with the consumer group.
If a tool inspects lags and compares
y a lag of "1" in this kind of situation
Best regards,
Vincent
On 13/06/2023 17:27, Matthias J. Sax wrote:
Sounds like a bug in aiokafka library to me.
If the last message in a topic partition is a tx-marker, the consumer
should step over it, and report the correct position after the
Congrats!
On 7/10/23 8:45 AM, Chris Egerton wrote:
Hi all,
The PMC for Apache Kafka has invited Greg Harris to become a committer, and
we are happy to announce that he has accepted!
Greg has been contributing to Kafka since 2019. He has made over 50 commits
mostly around Kafka Connect and Mirr
The class `RocksDbSessionBytesStoreSupplier` is in package `internal`
and thus, you should not use it directly. Instead, you should use the
public factory class `org.apache.kafka.streams.state.Stores`
However, your usage seems correct in general.
Not sure why you pass-in the supplier directly
Sounds like a bug in aiokafka library to me.
If the last message in a topic partition is a tx-marker, the consumer
should step over it, and report the correct position after the marker.
The official KafkaConsumer (ie, the Java one), does the exact same thing.
-Matthias
On 5/30/23 8:41 AM, V
Thanks a lot!
-Matthias
On 5/21/23 7:27 PM, Luke Chen wrote:
Hi Matthias,
Yes, I agree we should get this hotfix into 3.4.1.
I've backported into the 3.4 branch.
I'll create a new RC for 3.4.1.
Thanks.
Luke
On Mon, May 22, 2023 at 5:13 AM Matthias J. Sax wrote:
Hi Luke,
RC0
Hi Luke,
RC0 for 3.4.1 includes a fix for
https://issues.apache.org/jira/browse/KAFKA-14862. We recently
discovered that tge fix itself introduces a regression. We have already
a PR to fix-forward the regression:
https://github.com/apache/kafka/pull/13734
I think we should get the open PR m
Does having 9 partitions with 9 replication factors make sense here?
A replication factor of 9 sounds very high. For production, replication
factor of 3 is recommended.
How many partitions you want/need is a different question, and cannot be
answered in a general way.
"Yes" to all other
m the users about the community's 12 month EOL policy.
I will get back on this thread once I have more data to support the
proposal.
--
Divij Vaidya
On Thu, Apr 20, 2023 at 3:52 AM Matthias J. Sax wrote:
While I understand the desire, I tend to agree with Ismael.
In general, it'
Congrats Mickael!
And thanks a lot for taking on this additional task! Glad to have you!
-Matthias
On 4/21/23 9:40 AM, Viktor Somogyi-Vass wrote:
Jun, thank you for all your hard work! Also, congrats Mickael, it is very
well deserved :)
Best,
Viktor
On Fri, Apr 21, 2023, 18:15 Adam Bellemar
In general there is no ordering guarantee between topics. So it might
depend a lot ofnthe details of your use case.
For example, if you know that it will be always two event, you could
buffer the first one in a state-store, and wait for the second one to
arrive and decide in which order to for
Congrats!
On 3/9/23 2:59 PM, José Armando García Sancio wrote:
Congrats Chris.
On Thu, Mar 9, 2023 at 2:01 PM Kowshik Prakasam wrote:
Congrats Chris!
On Thu, Mar 9, 2023 at 1:33 PM Divij Vaidya wrote:
Congratulations Chris! I am in awe with the amount of effort you put in
code reviews an
Congrats!
On 3/9/23 2:59 PM, José Armando García Sancio wrote:
Congrats David!
On Thu, Mar 9, 2023 at 2:00 PM Kowshik Prakasam wrote:
Congrats David!
On Thu, Mar 9, 2023 at 12:09 PM Lucas Brutschy
wrote:
Congratulations!
On Thu, Mar 9, 2023 at 8:37 PM Manikumar
wrote:
Congrats David!
Hmmm... that's interesting...
It seems that Kafka Streams "version probing" does not play well static
group membership...
Sounds like a "bug" to me -- well, more like a missing integration. Not
sure right now, if/how we could fix it.
Can you file a ticket?
For now, I don't think you can do
Thanks for reaching out.
Can you open a PR against https://github.com/apache/kafka-site updating
`powered-by.html`?
-Matthias
On 2/1/23 1:13 AM, Tali Soroker wrote:
Hi,
I am writing on behalf of Coralogix to request adding us to the Powered
By page on the Apache Kafka website.
I am attac
| Senior Software Developer | *ude...@itrsgroup.com*
<mailto:ude...@itrsgroup.com>
*www.itrsgroup.com* <https://www.itrsgroup.com/>
<https://www.itrsgroup.com/>
*From: *Matthias J. Sax
*Date: *Wednesday, January 18, 2023 at 12:50 AM
*To: *users@kafka.ap
Guess it depends what you actually want to achieve?
Also note: `InMemoryWindowStore` is an internal class, and thus might
change at any point, and it was never designed to be extended...
-Matthias
On 1/13/23 2:55 PM, Upesh Desai wrote:
Hello all,
I am currently working on creating a new In
Congrats!
On 1/17/23 1:26 PM, Ron Dagostino wrote:
Congratulations, Stan!
Ron
On Jan 17, 2023, at 12:29 PM, Mickael Maison wrote:
Congratulations Stanislav!
On Tue, Jan 17, 2023 at 6:06 PM Rajini Sivaram wrote:
Congratulations, Stan!
Regards,
Rajini
On Tue, Jan 17, 2023 at 5:04 PM
Dear community,
I am pleased to announce Walker Carlson as a new Kafka committer.
Walker has been contributing to Apache Kafka since November 2019. He
made various contributions including the following KIPs.
KIP-671: Introduce Kafka Streams Specific Uncaught Exception Handler
KIP-696: Update
Congrats!
On 1/6/23 5:15 PM, Luke Chen wrote:
Congratulations, Edoardo!
Luke
On Sat, Jan 7, 2023 at 7:58 AM Mickael Maison
wrote:
Congratulations Edo!
On Sat, Jan 7, 2023 at 12:05 AM Jun Rao wrote:
Hi, Everyone,
The PMC of Apache Kafka is pleased to announce a new Kafka committer
Edo
Congrats!
On 12/29/22 6:47 PM, ziming deng wrote:
Congratulations Justine!
—
Best,
Ziming
On Dec 30, 2022, at 10:06, Luke Chen wrote:
Congratulations, Justine!
Well deserved!
Luke
On Fri, Dec 30, 2022 at 9:15 AM Ron Dagostino wrote:
Congratulations, Justine!Well-deserved., and I’m v
Sounds like a SpringBoot issue rather than a KS issues.
-Matthias
On 12/29/22 2:45 AM, Nawal Sah wrote:
Hi,
My SpringBoot stream application works fine in a fresh start of the
clustered environment.
But when I restart one of the pods out of two pods, I start getting the
below exception from "K
Congrats!
On 12/27/22 10:20 AM, Kirk True wrote:
Congrats, Satish!
On Fri, Dec 23, 2022, at 10:07 AM, Jun Rao wrote:
Hi, Everyone,
The PMC of Apache Kafka is pleased to announce a new Kafka committer Satish
Duggana.
Satish has been a long time Kafka contributor since 2017. He is the main
dri
Congrats!
On 12/20/22 12:01 PM, Josep Prat wrote:
Thank you all!
———
Josep Prat
Aiven Deutschland GmbH
Immanuelkirchstraße 26, 10405 Berlin
Amtsgericht Charlottenburg, HRB 209739 B
Geschäftsführer: Oskari Saarenmaa & Hannu Valtonen
m: +491715557497
w: aiven.io
e: josep.p...@aiven.io
On
Congrats!
On 12/15/22 7:09 AM, Rajini Sivaram wrote:
Congratulations, Ron! Well deserved!!
Regards,
Rajini
On Thu, Dec 15, 2022 at 11:42 AM Ron Dagostino wrote:
Thank you, everyone!
Ron
On Dec 15, 2022, at 5:09 AM, Bruno Cadonna wrote:
Congrats Ron!
Best,
Bruno
On 15.12.22 10:23,
Congrats!
On 12/15/22 7:10 AM, Rajini Sivaram wrote:
Congratulations, Viktor!
Regards,
Rajini
On Thu, Dec 15, 2022 at 11:41 AM Ron Dagostino wrote:
Congrats to you too, Victor!
Ron
On Dec 15, 2022, at 4:59 AM, Viktor Somogyi-Vass <
viktor.somo...@cloudera.com.invalid> wrote:
Thank
don't think that there is any guarantee that you might "see"
concurrent modification (IIRC, RocksDB uses snapshot isolation for
iterators). But maybe that's good enough for you?
-Matthias
On 11/7/22 11:13 AM, Joshua Suskalo wrote:
"Matthias J. Sax" writes:
ently used iterator is
concurrent, there is no API contract about it.
-Matthias
On 11/7/22 7:41 AM, Joshua Suskalo wrote:
Hello Matthias, thanks for the response!
"Matthias J. Sax" writes:
Spanning your own thread and calling context.forward() is _not_ safe, and there
is currently
Your observation is correct. The Processor#process() and punctuation
callback are executed on a single thread. It's by design to avoid the
issue of concurrency (writing thread safe code is hard and we want to
avoid putting this burden onto the user). There is currently no plans to
make process(
Congrats!
On 11/1/22 7:08 PM, Luke Chen wrote:
Congrats Bruno!
Well deserved!
Luke
On Wed, Nov 2, 2022 at 10:07 AM John Roesler wrote:
Congratulations, Bruno!!!
On Tue, Nov 1, 2022, at 15:16, Lucas Brutschy wrote:
Wow, congratulations!
On Tue, Nov 1, 2022 at 8:55 PM Chris Egerton
wrote
1 - 100 of 1015 matches
Mail list logo
