作者 唐旭辉

.

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