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?
