From the course: Complete Guide to Apache Kafka for Beginners
Unlock the full course today
Join today to access over 25,200 courses taught by industry experts.
Wikimedia producer run - Kafka Tutorial
From the course: Complete Guide to Apache Kafka for Beginners
Wikimedia producer run
So let's run our code. And to do so, we must first create this Wikimedia dot recent change topic. So you can use the CLI or I'm going to use the Conduktor UI. So I'm going to create this topic of three partitions and a replication factor of one because we are only running one Kafka broker. So my topic is now created and what I'm going to do now is just run this code. So you can click on the play button here and let's see what happens when the log output comes. Okay. So if we have a look here, we have the producer configuration that is looking fine. And then in our log, we're starting to get an event source client using this URI. So we're starting to read from the stream and then as read from the stream, we get a lot of info log around all the data that is being sent to Apache Kafka. So as you can see, the stream is quite fast and it's happening in real time. And so therefore if I go into my consumer and I refresh right now,…
Practice while you learn with exercise files
Download the files the instructor uses to teach the course. Follow along and learn by watching, listening and practicing.
Contents
-
-
-
-
-
-
-
-
-
(Locked)
Wikimedia producer project setup6m 25s
-
(Locked)
Wikimedia producer implementation11m 54s
-
(Locked)
Wikimedia producer run2m 40s
-
Wikimedia producer: Producer config intros45s
-
(Locked)
Producer acknowledgments deep dive8m 48s
-
(Locked)
Producer retries3m 3s
-
(Locked)
Idempotent producer2m 52s
-
(Locked)
Safe Kafka producer settings1m 59s
-
(Locked)
Wikimedia producer safe producer implementation4m 3s
-
(Locked)
Kafka message compression4m 47s
-
(Locked)
linger.ms and batch.size producer settings3m 23s
-
(Locked)
Wikimedia producer high-throughput implementation3m 16s
-
(Locked)
Producer default partitioner and sticky partitioner4m 18s
-
(Locked)
[Advanced] max.block.ms and buffer.memory2m 39s
-
(Locked)
-
-
-
-
-
-