?

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

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

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

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。