Learning Kafka By Example
- SimpleProducer:Kafka生产者发送消息的基本用法
- ConsumerGroup:Kafka消费者群组的基本用法
- ProducerWithPartitioner:演示自定义分区器的用法,根据value长度进行分区
- WordCountDemo:word count词频统计,基本用法
- MapFunctionDemo:演示map的基本用法(将输入字符串转换成大写)
- TimeWindowsDemo:Kafka的TimeWindows操作,在时间窗口内进行聚合操作
更新中...