update type

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

@@ -18,6 +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)
     val userInfo: UserInfo = JSON.parseObject(info, classOf[UserInfo])
     userInfo
   }

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

@@ -5,6 +5,6 @@ case class UserInfo(
     action: String,
     logTime: Double,
     eventCn: String,
-    secondDemands: List[String],
-    projects: List[String]
+    secondDemands: Array[String],
+    projects: Array[String]
 )