【golang】go 使用sarama写入kafka数据时间戳问题

日期： 2020-09-18 分类：个人收藏 367次阅读

查看消息时间戳的命令：
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

除特别声明，本站所有文章均为原创，如需转载请以超级链接形式注明出处：SmartCat's Blog

标签：golang golang kafka

上一篇：网络空间安全关键技术研究

下一篇：三方面分析：2020年Java开发就业前景如何？