我有一个springboot应用程序(spring version 2.2.2.RELEASE),我在其中配置了Kafka消费者,它处理来自Kafka的数据,并为多个web套接字提供服务。订阅kafka成功,但并不是所有选中Kafka topic的消息都会被消费者处理。很少有消息被延迟,也很少有消息被遗漏。但生产者正在发送数据,这是完全有保障的。下面我已经分享了
我正在尝试创建一个springboot应用程序(Java),它必须能够通过给出偏移量和分区来删除kafka主题中的消息。我一直在研究可以做到这一点的java或springboot包类,但我只发现了这样的东西:Delete Messages from a Topic in Apache Kafka有一个javakafka客户端,它有一个方法可以删除偏移前的所有消息</e