Error specifying Kafka params from Java

Hi all, I get the following exception when trying to build a Kafka input DStream with custom properties from Java. I am wondering if it's a problem with the Java to Scala binding - I am at a loss for what I could be doing wrong. 14/04/10 16:46:28 ERROR NetworkInputTracker: De-registered rec

Error specifying Kafka params from Java

Hi all, I get the following exception when trying to build a Kafka input DStream with custom properties from Java. I am wondering if it's a problem with the Java to Scala binding - I am at a loss for what I could be doing wrong. 14/04/10 16:46:28 ERROR NetworkInputTracker: De-registered receive