gocommon upgrage

@@ -14,7 +14,7 @@ require (
 	//github.com/opentracing/opentracing-go v1.1.1-0.20190913142402-a7454ce5950e
 	//github.com/openzipkin-contrib/zipkin-go-opentracing v0.4.5
 	//github.com/openzipkin/zipkin-go v0.2.5
-	github.com/tiptok/gocomm v1.0.8
+	github.com/tiptok/gocomm v1.0.9
 )
 
 //replace github.com/tiptok/gocomm v1.0.8 => F:\go\src\learn_project\gocomm

@@ -17,7 +17,7 @@ const (
 )
 
 func RunConsumer() {
-	saramaConsumer := kafkax.NewSaramaConsumer(KAFKA_HOSTS, GroupId) // models.WithVersion("0.10.2.1")
+	saramaConsumer := kafkax.NewSaramaConsumer(KAFKA_HOSTS, GroupId) //models.WithHandlerOriginalMessageFlag(true)   models.WithVersion("0.10.2.1")
 	saramaConsumer.WithTopicHandler(TOPIC_BUSSINESS_ADMIN, UserLoginHandler)
 	saramaConsumer.WithMessageReceiver(local.NewPgMessageReceiverRepository(pg.DB, nil)) // 持久化