...
|
...
|
@@ -3,7 +3,6 @@ package consumer |
|
|
import (
|
|
|
"github.com/Shopify/sarama"
|
|
|
"github.com/astaxie/beego/logs"
|
|
|
"gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/port/consumer/handles"
|
|
|
)
|
|
|
|
|
|
//TopicHandle 处理kafka中得消息
|
...
|
...
|
@@ -19,5 +18,5 @@ var TopicHandleRouters = map[string]TopicHandle{ |
|
|
message.Timestamp, message.Topic, message.Offset, string(message.Value))
|
|
|
return nil
|
|
|
},
|
|
|
"xiangmi-orders": handles.DataFromXiangMi,
|
|
|
//"xiangmi-orders": handles.DataFromXiangMi,
|
|
|
} |
...
|
...
|
|