sparkStreaming+Kafka问题

JavaPairReceiverInputDStream<String, String> dataStream = KafkaUtils.createStream(jssc, zkQuorum, group, topicmap);
使用KafkaUtils.createStream接收kafka发送的数据，返回的是key-value形式，可是key值为null, 怎么设置才能使key值不为null呢？是在kafka发送端设置还是在sparkStreaming端设置，怎么设置？

这是整个流程的，还有你的代码实现。
建议调试下。
首先确保，发送key不能null，然后在设置。

调试参考
Spark 1.5.0 远程调试
http://www.aboutyun.com/forum.php?mod=viewthread&tid=15679

Spark通过IntelliJ IDEA远程调试

http://www.aboutyun.com/forum.php?mod=viewthread&tid=9877


更多可以自己找找