add printer

41ee533f · 赵威 · 2162ab05 · 41ee533f
Commit 41ee533f authored Feb 04, 2021 by 赵威
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 3 deletions

Main.scala src/main/scala/com.gmei.up/Main.scala +2 -3

No files found.
--- a/src/main/scala/com.gmei.up/Main.scala
+++ b/src/main/scala/com.gmei.up/Main.scala
@@ -26,9 +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)
-    println("##############")
-    println(consumerRecord.topic())
-    println(consumerRecord.value())
+    val value = consumerRecord.value()
+    value.foreach(println)
    println("##############")
    KafkaUserInfo(
      "abc",