是否有方法设置偏移量的时间戳,以便从使用Quarkus/Smallrye消息开始?
还是回到特定的偏移量上?
发布于 2022-06-09 19:31:21
偏移量存储在kafka中,您可以重置如下主题:
kafka-consumer-groups --bootstrap-server <kafkahost:port> --group <group_id> --topic <topic_name> --reset-offsets --to-earliest --executehttps://stackoverflow.com/questions/72564699
复制相似问题