add printer

src/main/scala/com.gmei.up/Main.scala

@@ -26,8 +26,8 @@ class UserInfoDeserializationSchema extends KafkaDeserializationSchema[KafkaUser
   override def deserialize(consumerRecord: ConsumerRecord[Array[Byte], Array[Byte]]): KafkaUserInfo = {
     // KafkaUserInfo(consumerRecord.topic(), new String(consumerRecord.value(), "UTF-8"))
     println(consumerRecord)
-    val value = consumerRecord.value()
-    value.foreach(println)
+    val value = new String(consumerRecord.value(), "UTF-8")
+    println(value)
     println("##############")
     KafkaUserInfo(
       "abc",