Skip to content

S
streamingUserPortrait
Commit 2162ab05 authored by 赵威's avatar 赵威
Browse files
Options

add printer

parent da90b6b6
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 0 deletions
src/main/scala/com.gmei.up/Main.scala
View file @ 2162ab05
...@@ -26,6 +26,10 @@ class UserInfoDeserializationSchema extends KafkaDeserializationSchema[KafkaUser ...@@ -26,6 +26,10 @@ class UserInfoDeserializationSchema extends KafkaDeserializationSchema[KafkaUser
override def deserialize(consumerRecord: ConsumerRecord[Array[Byte], Array[Byte]]): KafkaUserInfo = { override def deserialize(consumerRecord: ConsumerRecord[Array[Byte], Array[Byte]]): KafkaUserInfo = {
// KafkaUserInfo(consumerRecord.topic(), new String(consumerRecord.value(), "UTF-8")) // KafkaUserInfo(consumerRecord.topic(), new String(consumerRecord.value(), "UTF-8"))
println(consumerRecord) println(consumerRecord)
println("##############")
println(consumerRecord.topic())
println(consumerRecord.value())
println("##############")
KafkaUserInfo( KafkaUserInfo(
"abc", "abc",
"abc", "abc",
......
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