Commit 530d3f98 authored by 赵威's avatar 赵威

add printer

parent 96cafa2c
...@@ -18,7 +18,7 @@ class UserInfoDeserializationSchema extends KafkaDeserializationSchema[UserInfo] ...@@ -18,7 +18,7 @@ class UserInfoDeserializationSchema extends KafkaDeserializationSchema[UserInfo]
override def deserialize(consumerRecord: ConsumerRecord[Array[Byte], Array[Byte]]): UserInfo = { override def deserialize(consumerRecord: ConsumerRecord[Array[Byte], Array[Byte]]): UserInfo = {
val info = new String(consumerRecord.value(), "UTF-8") val info = new String(consumerRecord.value(), "UTF-8")
// println(info) println(info)
val userInfo: UserInfo = JSON.parseObject(info, classOf[UserInfo]) val userInfo: UserInfo = JSON.parseObject(info, classOf[UserInfo])
userInfo userInfo
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment