Kafkacat在使用时间戳消费时计算记录数时出现错误

此问题可能是由于不同时间戳的记录混淆导致的。为避免这种情况发生，可以使用Kafkacat的-o选项将偏移量设置为记录的时间戳。示例代码如下：

kafkacat -C -b broker:9092 -t topic -o end -o timestamp -e -f '\nPartition: %p\nOffset: %o\nTimestamp: %T\nKey: %k\nValue: %s\nHeaders: %h\n' | awk 'BEGIN { count=0 } /^Partition:/ { count++ } END { print count }'

此代码将消费名为“topic”的Kafka主题，设置偏移量为记录的时间戳，并使用awk命令计算记录数。