Help Center/ MapReduce Service/ Developer Guide (LTS)/ Kafka Development Guide (Security Mode)/ Developing an Application/ Kafka Streams Scenario Description
Updated on 2022-11-18 GMT+08:00
View PDF

Kafka Streams Scenario Description

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.