The Ultimate Kafka Streams (3.x) : Real-time Data Processing

سرفصل های دوره

Apache Kafka Streams: Stateless Streams, Stateful Streams, KTable, Window, Statestore, RocksDB,Real-Time data analysis

1. Course Introduction

1. Course content introduction

2. Course objective and scope

3. Course Characteristics & how to learning (suggestions)

4.1 The Ultimate Apache Kafka Streams Real-time Data Processing.pptx

4.2 udemy-kafka-streams.zip

4. Download the source code & PowerPoint.html

2. Apache Kafka Streams Introduction

1. What is Kafka Streams

2. Kafka Streams Key Terms

3. Kafka Streams Parallel mode

4. Data process strategy in Kafka Streams

5. Kafka Streams Development Environment Setup(Kafka Broker Setup)

6. Kafka Streams Development Environment setup(Maven Project)

7. Quick Start-Develop First Kafka Streams Application

8. Setup the First Kafka Stream Application and Testing

3. Build Kafka Stateless Streams Application

1. What is stateless streams application

2. Stateless Operation- Map & KeyValueMapper

3. Stateless Operation- MapValues & ValueMapper & ValueMapperWithKey

4. Stateless Operation- Filter & FilterNot & Predicate

5. Stateless Operation-FlatMap & KeyValueMapper

6. Stateless Operation-FlatMapValues&ValueMapper&ValueMapperWithKey

7. Stateless Operation-SelectKey & KeyValueMapper

8. Stateless Operation-Foreach & ForeachAction

9. Stateless Operation-Print and Peek

10. Stateless Operation-(BranchedKStream)Split Streams to multiple sub-streams

11. Stateless Operation-Merge Small KStreams to big one

12. Stateless Operation-Sink the transformed records to target topic

13. Assemble Together XMall Transaction data real-time analysis practise

14. Assemble Together XMall Transaction data real-time analysis - Data Model Define

15. Assemble Together XMall Transaction data real-time analysis-Custom Serdes

16. Assemble Together XMall Transaction data real-time analysis-Streams Application

17. Assemble Together XMall Transaction data real-time analysis-Deploy & Testing

18. Kafka Stateless Streams Recap & Summarize

4. Build Kafka Stateful Streams application & statestore(RocksDB)

1. What is stateful streams application

2. State store & state store solution

3. Stateful transformation practical (Word Count)

4. Stateful transformation practical(Word Count) test and result verify

5. Understand the Kafka streams internal data redistribution and stateful transform

6. Enhancement XMall transaction reward point processor support total reward points

7. Stateful transform operations

8. KStream Joining operation introduction

9. KStream inner joining operation

10. KStream inner joining operation application startup & testing

11. Depth understand the joining operation and underlying change logs

12. KStream left joining operation

13. KStream outer joining operation

14. KStream grouping operation

15. KGroupedStream count aggregation operation practical(word count)

16. KGroupedStream reduce aggregation operation practical(word count)

17. Real-Time analysis the sales champion application by reduce aggregate operation

18. Develop the sales champion application by reduce aggregating operation and test

19. KGroupedStream aggregate operation for Real-Time compute sales stats reporter

20. Stateful KStream Queryable Storestore(KeyValueStore)-single instance

21. Stateful KStream Queryable Storestore(KeyValueStore)-multiple instance

22. Stateful process and ProcessorSupplier(Official documentation has bugs)

23. Kafka Stateful Streams Recap & Summarize

5. Build complex streaming application with KGroupedStream windowing operation

1. Kafka Streams Time Semantics

2. Kafka LogAppendTime&CreateTime

3. Kafka Streams TimestampExtractor

4. The Kafka Streams Windowing Operation introduction

5. Tumbling time window analyzes network attack behavior in real time

6. Tumbling time window real-time analysis of network attack behavior app building

7. Suppress some updates from this changelog stream

8. Hopping time window for real-time statistics the website access traffic

9. Sliding time window for real-time statistics the website access traffic

10. Hopping time window vs Sliding time window.html

11. Session time window for real-time statistics website PV&UV

12. Assembly-Heartbeat sensor data real-time analysis patient health monitoring-I

13. Assembly-Heartbeat sensor data real-time analysis patient health monitoring-II

14. Assembly-Heartbeat sensor data real-time analysis patient health monitoring-III

15. KGroupedStream Interactive Queryable Storestore(WindowStore)

16. KGroupedStream & Windowing Aggregation Recap and Summarize

6. Build Updatable Streams Application with KTable

1. What is KTable

2. Create KTable from StreamsBuilder(Official documentation has bugs)

3. Create KTable from KStream

4. KTable basic operation introduction and Tombstone records explanation

5. Lab KTable basic operation exercises(contains tombstone records)

6. KTable transformValues operation and shoot game

7. KStream inner join the KTable

8. KStream left join the KTable

9. KTable inner join the KTable

10. KTable Foreign Key inner join the KTable

11. KTable supported joining operations

12. KTable grouping & count aggregating count the number of employees

13. KTable grouping & reduce aggregating statistics department total salary

14. KTable grouping & aggregate aggregating statistics department total salary

15. KTable Recap and Summarize

7. GlobalKTable API

1. What is GlobalKTable

2. GlobalKTable vs KTable

3. KStream joining(inner&left) GlobalKTable

139,000 تومان

خرید اشتراک افزودن به سبد خرید

خرید دانلودی فوری

در این روش نیاز به افزودن محصول به سبد خرید و تکمیل اطلاعات نیست و شما پس از وارد کردن ایمیل خود و طی کردن مراحل پرداخت لینک های دریافت محصولات را در ایمیل خود دریافت خواهید کرد.

تولید کننده: Udemy-Training