如何调试Smallrye Reactive Messaging的throttled.unprocessed-record-max-age.ms及日志疑问

关于日志中的183504174是什么？ #

在这条Kafka日志里，183504174就是该消息的偏移量，并非实际记录内容。Kafka中，偏移量（offset）是分区内消息的唯一序号，用来标记消息在分区里的位置。日志里的"The record 183504174"实际指的是偏移量为183504174的这条消息。

能否直接定位偏移量183504174找到异常消息？ #

可以直接定位到topic-partition xxxxxx-11的偏移量183504174排查异常，原因如下：

• 日志显示最后提交的偏移量是183504173，说明消费者已成功处理并提交了该偏移量之前的所有消息；
• 偏移量183504174的消息等待ACK超过60秒，正是当前卡住未被确认的消息，大概率就是引发问题的异常消息。

你可以用Kafka自带工具读取这条消息，示例命令：

kafka-console-consumer.sh --bootstrap-server <你的Kafka服务地址> --topic xxxxxx --partition 11 --offset 183504174 --max-messages 1

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