一、基本概念

Kafka Streams 是一个用于处理和分析数据的客户端库。它先把存储在 Kafka 中的数据进行处理和分析，然后将最终所得的数据结果回写到 Kafka 或发送到外部系统。

Kafka Streams 直接解决了流式处理中的很多问题：

• 毫秒级延迟的逐个事件处理。
• 有状态的处理，包括连接（join）和聚合类操作。
• 具有快速故障切换的分布式处理和容错能力。

二、终端命令行演示

首先创建两个主题streams-wordcount-output和streams-plaintext-input：

bin/kafka-topics.sh --create --topic streams-wordcount-output --bootstrap-server localhost:9092
Created topic streams-wordcount-output.
bin/kafka-topics.sh --create --topic streams-plaintext-input --bootstrap-server localhost:9092
Created topic streams-plaintext-input.

三、客户端开发

参考

官方文档 (opens new window)

图解Kafka之实战指南 (opens new window)