Kafka客户端消费订阅数据

最近更新时间:2020-02-21 14:28:18

前提条件

  • 已创建数据订阅通道。
  • 已创建消费组。

注意事项

订阅client消费数据如果使用auto commit,可能会因为数据还没消费完就commit了,导致丢失部分数据。建议采用手动commit,如果发生故障没有commit成功,重启后会从上一个记录的位点进行数据消费,期间会有部分重复数据,需要用户手动过滤。

金山云,开启您的云计算之旅

免费注册