檢視訊息時間戳的命令：
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
ubuntu下使用Docker安裝kafka
首先拉取zookeeper kafka映象 docker pull wurstmeister zookeeper docker pull wurstmeister kafka啟動zookeeper docker run d name zookeeper restart always publish ...
go 寫入yaml Golang 解析Yaml格式
golang官方並沒有提供yaml解析包，所以需要使用第三方包。可用的第三方包有不少，這裡選擇的是 這個包提供的函式還是很少了，這真是一件好事 如果你不了解yaml，檢視yaml簡要入門 func marshal in inte ce out byte,err error 將提供的物件解析為yaml...
go 寫入yaml Go語言解析YAML
本篇解析yaml，是為了使用go搭建乙個基於markdown的部落格系統，當做乙個專案。1 概述 yaml是 yaml ain t a markup language yaml不是一種置標語言 的遞迴縮寫。yaml 以資料為中心，使用空白，縮排，分行組織資料，從而使得表示更加簡潔易讀。乙個典型的 y...