spark 2.2 kafka [0.11,0.10]_2.11 jdk 1.8 zookeeper 3.4.6 { timestamp:String # yyyy-mm0dd HH:MM 格式时间戳字符串 count:Integer # 在 1 分钟时间范围内接收到的消息计数变量字段 } 写回到 kafka-topic: kafka-out-stream, partition 5, ...