Kafka Streams 101: Basic Operations (2023)

Рет қаралды 36,340

2 жыл бұрын

► TRY THIS YOURSELF: cnfl.io/kafka-streams-101-mod...
Learn how to start a Kafka Streams application by creating an instance of the StreamsBuilder class, and how to create a KStream.
Once you have your KStream, you can do things like transform your data with a mapping or filtering operation.
► For a COMPLETE IMMERSIVE HANDS-ON EXPERIENCE, go to cnfl.io/kafka-streams-101-mod...
--
ABOUT CONFLUENT
Confluent is pioneering a fundamentally new category of data infrastructure focused on data in motion. Confluent’s cloud-native offering is the foundational platform for data in motion - designed to be the intelligent connective tissue enabling real-time data, from multiple sources, to constantly stream across the organization. With Confluent, organizations can meet the new business imperative of delivering rich, digital front-end customer experiences and transitioning to sophisticated, real-time, software-driven backend operations. To learn more, please visit www.confluent.io.
#kafka #kafkastreams #streamprocessing #apachekafka #confluent

Пікірлер: 8

@nageshwarburman8819 11 ай бұрын

So far this series has been very good!

@svdfxd 9 ай бұрын

That's a great explanation !!

@RafaelSoares-Tuelho 2 жыл бұрын

Very well explained! Thanks.

@andreyy.k.9775 2 ай бұрын

Hi, there is a typo in the code at 1:53, StreamBuilder class does not exist, StreamsBuilder is what we need

@arvindhemamalini Жыл бұрын

Is it okay to use Kafka stream for multiple consumers with different data for each consumer?

@sumeght1878 12 күн бұрын

Yeah, provided you create separate Streams for each consumer, you want to filter, Consider this just like Java Stream API, which does not modify your actual dataset, rather creates an inmemory copy and delivers output only when a terminal operation is called

Жыл бұрын

I love the explanation, but I really don't get how this is done in Java instead of Scala, when the whole abstraction would be so much easier to udnerstand