Cell phone I would like to use the sparkstraming analysis kafka log4j logging, the same thread of the log, integrated into a message, divided into RDD, may belong to different RDD a log, could you tell me what's the solution? The analysis of the log to the same thread a record?