I've following code in my program.  I don't get any error, but it's not
consuming the messages either.  Shouldn't the following code print the line
in the 'call' method?  What am I missing?

Please help.  Thanks.



        JavaStreamingContext ssc = new JavaStreamingContext(sparkConf, new
Duration(60 * 1 * 1000));

        JavaPairReceiverInputDStream tweets = KafkaUtils.createStream(ssc,
"<machine>:2181", "1", map);

        JavaDStream<String> statuses = tweets.map(
                new Function<String, String>() {
                    public String call(String status) {
                        System.out.println(status);
                        return status;
                    }
                }
        );

Reply via email to