KafkaExample

KafkaExample copied to clipboard

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