Merge branch 'package' of GameCenter/game-center into dev

game-module/game-module-sdk/src/main/java/com/zanxiang/game/module/sdk/SDKApplication.java

@@ -23,7 +23,7 @@ public class SDKApplication {
 
     public static void main(String[] args) {
         SpringApplication.run(SDKApplication.class, args);
-        System.out.println("赞象SDK服务启动成功 <一大波修改> ( ´･･)ﾉ(._.`) \n" +
+        System.out.println("赞象SDK服务启动成功 <卡夫卡数据结构变化> ( ´･･)ﾉ(._.`) \n" +
                 " ___________ _   __\n" +
                 "/  ___|  _  \\ | / /\n" +
                 "\\ `--.| | | | |/ / \n" +

game-module/game-module-sdk/src/main/java/com/zanxiang/game/module/sdk/service/impl/KafkaServiceImpl.java

@@ -38,7 +38,8 @@ public class KafkaServiceImpl implements IKafkaService {
     @Override
     public void eventTrack(KafkaEventTrackEnum eventTrackEnum, String data) {
         try {
-            kafkaProducer.send(new ProducerRecord<>(this.gameEventTrackTopic, eventTrackEnum.getValue(), data));
+            kafkaProducer.send(new ProducerRecord<>(this.gameEventTrackTopic, eventTrackEnum.getValue(),
+                    eventTrackEnum.getValue() + "=" + data));
         } catch (Exception e) {
             log.error("玩家数据埋点发送到 Kafka 异常!, eventTrackTopic : {}, eventTrackEnum : {}, data : {}, e : {}",
                     this.gameEventTrackTopic, eventTrackEnum.getValue(), data, e.getMessage());