Help Center>
MapReduce Service>
Developer Guide (Normal_3.x)>
Kafka Development Guide (Normal Mode)>
Developing an Application>
Kafka Streams Sample Code Description
Updated on 2022-08-16 GMT+08:00
Kafka Streams Sample Code 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
- Create two topics on the Linux client to serve as the input and output topics.
- 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.
Parent topic: Developing an Application
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
The system is busy. Please try again later.
For any further questions, feel free to contact us through the chatbot.
Chatbot