Kafka使用示例
#Kafka 0.8.2.2示例
- Producer示例
- HashPartitioner示例 实现HashPartitioner从而保证key相同的消息被发送到同一个Partition
- RoundRobinPartitioner示例 提供RoundRobin消息路由算法，实现Load balance
- High Level Consumer示例 通过High level API中的consumer group实现group内的消息单播和group间的消息广播
- Low Level Consumer示例 使用Low level API可实现精确的消息消费控制
#Kafka 0.10.1.0示例
- Producer示例 Producer支持send callback
- Partitioner示例 Partitioner接口与旧版本相比有所区别，可以实现更多语义的消息路由/消息分发
- Consumer示例 Kafka 0.10.*版本中新的Consumer使用同一套API同时实现0.8.*及以前版本中的High Level API及Low Level API
- Stream Low Level Processor API示例
- Stream Topology示例 使用Kafka Stream的Low-level Processor API实现word count
- Stream DSL示例 通过Kafka Stream的DSL API实现word count功能
- Purchase Analysis 如何使用KStream与KTable Join，如何创建自己的Serializer/Deserializer和Serde，以及如何使用Kafka Stream的Transform和Kafka Stream的Window