如何使用python获取kafka主题的最新时间戳?
igetnqfo1#
从kafka0.10.2开始,消耗的每个记录都有一个时间戳。如果你想得到最新的记录,那么你必须在消费之前找到主题的结尾。如果不读取任何记录,就无法获取时间戳。如何访问时间戳应该参考您正在使用的库的文档。
1条答案
按热度按时间igetnqfo1#
从kafka0.10.2开始,消耗的每个记录都有一个时间戳。
如果你想得到最新的记录,那么你必须在消费之前找到主题的结尾。
如果不读取任何记录,就无法获取时间戳。
如何访问时间戳应该参考您正在使用的库的文档。