- kafka 连接框架已经做好,不需要重做,仅需要做好配置,除非需要连接不同的kafka
- consumer: 类上添加注解后当topic有新消息时会自动调用函数,不需要手动调用
- 当下示例为自动提交
- 需要手动提交需要修改配置文件,后续工作暂未完成,等待后续完成
- producer: 发送消息需要手动调用,并切需要重写callback方法,完成发送成功,失败的首位工作
kafkaclient
Folders and files
Name | Name | Last commit date | ||
---|---|---|---|---|
parent directory.. | ||||