Welcome to sign up for this course. This course is about Kafka Streams, and the course will cover each detail in the Kafka Streams framework in Depth. Also, I hope you will enable the video CCC function (captions ) as my mother tongue isn't English and the spoken language isn't very common. However, I can guarantee that the course information is comprehensive and step-by-step from the shallow end to the deep.
Kafka Streams is a client library that allows you to build microservices and applications, where the output and input data are stored on Kafka clusters. It blends the ease of creating and installing traditional Java and Scala apps on the user side with the advantages of Kafka's server-side clustering technology.
Start the Kafka Streams
A tutorial on the Kafka Stream's essential concepts and terms
Parallel Mode of Kafka Streams
Map transform is a stateless operation.
MapValues transforms statelessly.
Flat map transform is stateless and operates without a need for a license.
FlatMapValues transforms statelessly and without a need for a transformation.
SelectKey transform is a stateless operation.
Foreach is a stateless operation.
The operation that is not stateless Print&Peek
Stateless operation split and merge branches of KStream
How can I customize the Series
XML Transaction data real-time analysis practice
Instruction on the Kafka stateful operation as well as state store
In detail, explain the internal redistribution of data and the stateful transformation
The stateful function of Joining(inner join, left join, and outer join)
The stateful operation of grouping
Stateful operation of aggregation(count,reduce,aggregate)
Create Real-time analysis of the application for sales champions
Build Real-time analysis of sales statistics application
Stateful KStream Queryable Store store
Stateful TimeWindowedKStream is a state store that can be accessed for interactive.
KGroupedStream windowing operation
Time Semantics and custom-designed TimestampExtractor
Time window that is tumbling to analyze Potential Cyber Attacks
Hopping time window to Site Visit live-time stats
Real-time analysis of heartbeat sensor data to monitor the health of patients
What is KTable? And how do you build the KTable?
KTable base operations, such as map values and filtering
KTable's basis stateful operation transform values are used to implement the shooting game
KStream inner&left join the KTable enrichment/enhancement of the original records
KTable inner join, the internal foreign key that is shared with another KTable
KTable left join, left foreign join, outer join KTable
KTable & KGroupedTable aggregating operation such as count/reduce/aggregate
