john 8b0a0ee272 kafka第三方库sarama-cluster调整为johng-cn/sarama-cluster

2018-09-19 15:08:33 +08:00

..

gkafka_consumer.go

kafka第三方库sarama-cluster调整为johng-cn/sarama-cluster

2018-09-19 15:08:33 +08:00

gkafka_producer.go

kafka第三方库sarama-cluster调整为johng-cn/sarama-cluster

2018-09-19 15:08:33 +08:00

gkafka_topics.go

添加gkafka依赖包到vendor目录，并增加Topics方法获取kafa所有的topic

2018-06-21 13:56:10 +08:00

kafka.go

完成kafka客户端开发

2018-06-15 18:31:23 +08:00