如何使用Quarkus/Smallrye Kafka Messaging实现Kafka消息重放

两个能力都是Quarkus SmallRye Messaging原生支持的，不需要修改底层Kafka客户端或框架源码即可实现，具体用法如下：

按时间戳指定消费起点 #

• 框架提供了开箱即用的配置项，无需手写自定义seek逻辑：在消费者对应的channel配置中，添加mp.messaging.incoming.<自定义channel名>.seek-to-timestamp配置项，填入毫秒级Unix时间戳，消费者首次启动（无已提交消费位移时）会自动将所有订阅分区的消费位移定位到该时间点之后的第一条消息开始消费。
• 如果需要忽略消费者组已提交的历史位移，每次启动都强制从指定时间戳位置开始消费，只要把同channel下的seek-to-timestamp.policy配置为ALWAYS即可。

跳转至任意指定offset实现消息重放 #

这个能力同样原生支持，分两种使用场景：

• 启动前静态指定：如果启动时就已经确定要跳转的目标offset，可以直接配置mp.messaging.incoming.<自定义channel名>.seek-to-offset填入固定offset值；如果需要给不同分区指定不同的目标offset，用mp.messaging.incoming.<自定义channel名>.seek-to-partition-offsets配置，格式为分区号1:目标offset1,分区号2:目标offset2即可。和时间戳配置一致，也可以通过对应的policy配置选择是仅无已提交位移时生效，还是每次启动强制跳转。
• 运行时动态控制：如果需要在运行过程中动态触发重放（比如通过运维接口触发、按业务规则计算重放位置），可以直接通过框架提供的KafkaClientService拿到对应channel的原生KafkaConsumer实例，手动调用seek/seekToBeginning/seekToEnd等原生API即可，框架不会拦截这类操作，也不会和内置的消费、位移提交逻辑冲突。

注意事项：所有seek相关配置的执行优先级高于auto.offset.reset配置，只要触发了seek逻辑，就不会走earliest/latest这类默认重置规则。做消息重放时如果不想影响原有消费链路，建议给重放任务单独配置独立的group.id，避免重放过程中提交的位移干扰线上正常消费进度。

内容的提问来源于stack exchange，提问作者user432024