update printer

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

@@ -18,7 +18,7 @@ class UserInfoDeserializationSchema extends KafkaDeserializationSchema[UserInfo]
 
   override def deserialize(consumerRecord: ConsumerRecord[Array[Byte], Array[Byte]]): UserInfo = {
     val info = new String(consumerRecord.value(), "UTF-8")
-    println(info)
+    // println(info)
     val userInfo: UserInfo = JSON.parseObject(info, classOf[UserInfo])
     userInfo
   }

src/main/scala/com.gmei.up/utils/Redis.scala

@@ -16,6 +16,7 @@ object Redis {
     contentF.foreach { seq =>
       val ids = seq.map(c => c.id)
       if (ids.size > 0) {
+        println(ids.head, ids.tail)
         pRc4.lpush(key, ids.head, ids.tail)
         pRc4.expire(key, 60 * 60 * 24 * 15)
       }