采纳
c++ 调用kafka,rd_kafka_conf_set接口设置"auto.offset.reset"属性时遇到问题,场景如下:
用一个进程作为生产者,一直在生产发送topic的消息。
生产者消息没有被消费,当我消费者连接成功时,将会接收所有以往没有被消费过的消息,可我的使用场景是只需要接收当前时间产生的消息,之前的需要忽略掉。
我该设置的是服务器配置还是代码????
求大佬解答!!只需要接收当前时间产生的消息,之前的需要忽略掉,不管它有没有被消费过。