Please see Approach 2 in:

http://spark.apache.org/docs/latest/streaming-kafka-integration.html




> On May 13, 2015, at 6:10 AM, James King <jakwebin...@gmail.com> wrote:
> 
> I'm trying Kafka Direct approach (for consume) but when I use only this 
> config:
> 
> kafkaParams.put("group.id", groupdid);
> kafkaParams.put("zookeeper.connect", zookeeperHostAndPort + "/cb_kafka");
> 
> I get this 
> 
> Exception in thread "main" org.apache.spark.SparkException: Must specify 
> metadata.broker.list or bootstrap.servers
> 
> Zookeeper should have enough information to provide connection details?
> 
> or am I missing something?
> 
> 

Reply via email to