Hi Matthieu,
Yes, the ZK migrating to KRaft feature is already GA in v3.6.0.
Sorry, we forgot to update the document in the Kafka-site repo.
I've filed a PR for it: https://github.com/apache/kafka-site/pull/594
Thanks.
Luke
On Thu, Apr 4, 2024 at 6:14 AM Matthieu Patou wrote:
> I looked at
Changing the code to this...
assertTrue(outputTopic.isEmpty());
testDriver.advanceWallClockTime(Duration.ofMillis(2001));
leftTopic.pipeInput("1", "test string 3", 4002L);
testDriver.advanceWallClockTime(Duration.ofMillis(2001));
I looked at the notes for 3.7.x and the migration from ZK to Kraft is still
not marked as production ready.
I'm wondering what are the issues that people could be facing during the
migration.
If 4.0 is still planned to be the full removal for ZK, is there a plan for
something after 3.7 to mark
I believe you need to advanceWallClockTime
https://kafka.apache.org/24/javadoc/org/apache/kafka/streams/TopologyTestDriver.html#advanceWallClockTime-java.time.Duration-
Regards,
Shashwat Pandey
On Wed, Apr 3, 2024 at 5:05 PM Chad Preisler
wrote:
> Seems like there is some issue with the
Apologies for the delay, Bruno. Thank you so much for the excellent link and
for your inputs! Also, I would like to thank Matthias and yourself for the
guidance on the stalling issue in the Kafka Streams client. After restoring the
default value for the METADATA_MAX_AGE_CONFIG, I haven’t seen
Seems like there is some issue with the TopologyTestDriver. I am able to
run the same stream against Kakfa and I'm getting the output I expect. I'd
appreciate it if someone could confirm that there is an issue with the
TopologyTestDriver. If there is, any suggestions on how to test this type
of
Hello,
I'm confused about the outerJoin and when records are produced with the
following code.
Topology buildTopology() {
var builder = new StreamsBuilder();
var leftStream = builder.stream("leftSecondsTopic",
Consumed.with(Serdes.String(), Serdes.String()));
var
Congrats Christo!
-Bill
On Wed, Mar 27, 2024 at 4:03 AM Matthias J. Sax wrote:
> 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
Hi everyone,
As part of The ASF’s 25th anniversary campaign[1], we will be celebrating
projects and communities in multiple ways.
We invite all projects and contributors to participate in the following
ways:
* Individuals - submit your first contribution:
Hi Kafka users
Does any one have a document or ppt that showcases the capabilities of
Kafka along with any cost management capability?
i have a customer who is still using IBM MQM and rabbit MQ. I want the
client to consider kafka for messaging and data streaming. I wanted to seek
your expert
+1 (non-binding). I used the staged Scala 2.13 binaries and the staging
Maven repo for my testing. All seems to work fine. Thanks for doing the
release.
Jakub
On Thu, Mar 28, 2024 at 10:51 AM Manikumar wrote:
> Hello Kafka users, developers and client-developers,
>
> This is the second
Gentle reminder. Please download, test and vote for the release.
Thanks,
On Fri, Mar 29, 2024 at 4:57 PM Manikumar wrote:
> Hi All,
>
> System test runs are green. There were 13 test failures in the first run.
> All the failed tests passed in the second run.
>
> System test results:
>
12 matches
Mail list logo
