调试

@@ -79,7 +79,7 @@ spec:
             - name: BUSINESS_ADMIN_HOST
             - name: BUSINESS_ADMIN_HOST
               value: "http://suplus-business-admin-dev.fjmaimaimai.com"
               value: "http://suplus-business-admin-dev.fjmaimaimai.com"
             - name: KAFKA_HOST
             - name: KAFKA_HOST
-              value: "192.168.0.250:9092"
+              value: "192.168.0.250:9092;192.168.0.251:9092;192.168.0.252:9092"
             - name: KAFKA_CONSUMER_ID
             - name: KAFKA_CONSUMER_ID
               value: "partnermg_dev"
               value: "partnermg_dev"
       volumes:
       volumes:

@@ -1081,7 +1081,7 @@ func (service OrderInfoService) PayPartnerBonusWithOrderBestshop(orderId int64,
 	})
 	})
 	err = orderBonuSrv.PayOrderGoodBonus(orderId, goodId, adminId)
 	err = orderBonuSrv.PayOrderGoodBonus(orderId, goodId, adminId)
 	if err != nil {
 	if err != nil {
-		return lib.ThrowError(lib.INTERNAL_SERVER_ERROR, err.Error())
+		return err
 	}
 	}
 	err = transactionContext.CommitTransaction()
 	err = transactionContext.CommitTransaction()
 	if err != nil {
 	if err != nil {

@@ -98,9 +98,6 @@ func (r *Runer) InitConsumer() error {
 	//config.Consumer.Group.Rebalance.Strategy = sarama.BalanceStrategyRoundRobin
 	//config.Consumer.Group.Rebalance.Strategy = sarama.BalanceStrategyRoundRobin
 	config.Consumer.Offsets.Initial = sarama.OffsetOldest
 	config.Consumer.Offsets.Initial = sarama.OffsetOldest
 	config.Version = sarama.V0_10_2_1
 	config.Version = sarama.V0_10_2_1
-	// config.Version = sarama.KafkaVersion{
-	// 	version: [4]int{},
-	// }
 	consumerGroup, err := sarama.NewConsumerGroup(r.msgConsumer.kafkaHosts, r.msgConsumer.groupId, config)
 	consumerGroup, err := sarama.NewConsumerGroup(r.msgConsumer.kafkaHosts, r.msgConsumer.groupId, config)
 	if err != nil {
 	if err != nil {
 		return err
 		return err