?

查看消息時間戳的命令：
kafka-console-consumer --bootstrap-server localhost:9092 --property print.timestamp=true --topic test --from-beginning
發現sarama生產者推送到kafka的CreateTime均為-1。而命令行推送到kafka的時間戳正常。

原因：
sarama默認支持的是0.8.2的kafka版本，而timestamp的支持是從0.10版本開始的。因此需要初始化生產者配置時指定一下kafka的版本。

kfkConf := sarama.NewConfig() kfkConf.Version = sarama.V0_10_0_0

總結

以上是生活随笔為你收集整理的go 使用sarama写入kafka数据时间戳问题的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。