diff --git a/src/main/scala/com.gmei.up/Main.scala b/src/main/scala/com.gmei.up/Main.scala index 0b31d7df3f3ad0bf903384023c3c4a24248f0b1f..11ff8d35fc1b18e26dc7fdedcc9e1687b1ac027f 100644 --- 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",