Kafka Streams Sample Code Description

Updated on 2022-09-14 GMT+08:00

Scenario Description

Kafka Streams is a lightweight stream processing framework provided by Apache Kafka. The input and output of Kafka Streams are stored in the Kafka cluster.

The following describes the most common WordCount samples.

Development Guideline

  1. Create two topics on the Linux client to serve as the input and output topics.
  2. Develop a Kafka Streams to implement the word count function. The system collects statistics on the number of words in each message by reading the message in the input topic, consumes data from the output topic, and outputs the statistical result in the form of a key-value pair.
Feedback

Feedback

Feedback

0/500

Selected Content

Submit selected content with the feedback