|
...
|
...
|
@@ -114,7 +114,7 @@ func (r *Runer) InitConsumer() error { |
|
|
|
clusterCfg.Consumer.Offsets.Initial = sarama.OffsetOldest
|
|
|
|
clusterCfg.Group.Return.Notifications = true
|
|
|
|
clusterCfg.Version = sarama.V0_10_2_1
|
|
|
|
khosts := []string{"192.168.0.252:9092"}
|
|
|
|
khosts := []string{"192.168.0.252:9092,192.168.0.251:9092"}
|
|
|
|
groupid := "partnermg_dev"
|
|
|
|
topic := []string{"topic_test"}
|
|
|
|
// consumer, err := cluster.NewConsumer(r.msgConsumer.kafkaHosts, r.msgConsumer.groupId, r.msgConsumer.topics, clusterCfg)
|
...
|
...
|
|
