返回到文章

采纳

编辑于 2年前

c++ 调用kafka,rd_kafka_conf_set接口设置"auto.offset.reset"属性问题

kafka

c++ 调用kafka,rd_kafka_conf_set接口设置"auto.offset.reset"属性时遇到问题,场景如下:

  1. 用一个进程作为生产者,一直在生产发送topic的消息。

  2. 生产者消息没有被消费,当我消费者连接成功时,将会接收所有以往没有被消费过的消息,可我的使用场景是只需要接收当前时间产生的消息,之前的需要忽略掉。

我该设置的是服务器配置还是代码????

求大佬解答!!只需要接收当前时间产生的消息,之前的需要忽略掉,不管它有没有被消费过。