Many thanks for the responses. Harsh your response has clarified things a bit for me.
I'm trying from Spark: KafkaUtils.createStream(spark, "zkHos:2181", "groupid", topics); And wasn't sure what value i should use for 'group' in consumer docs it says default is groupid so used that. But will read further to be more clear on this. Thanks. On Tue, Mar 31, 2015 at 3:44 PM, Harsha <ka...@harsha.io> wrote: > Hi James, > Can you elaborate on what you mean by group here?. There are no > groups on the topic side but there are consumer groups and these will be on > consumer side . > "Consumers label themselves with a consumer group name, and each message > published to a topic is delivered to one consumer instance within each > subscribing consumer group. Consumer instances can be in separate processes > or on separate machines.” > More info on this page http://kafka.apache.org/documentation.html look > for "consumer group”. > > > -- > Harsha > > > On March 31, 2015 at 6:10:59 AM, James King (jakwebin...@gmail.com) wrote: > > I created a topic using: > > bin/kafka-topics.sh --create --zookeeper localhost:2181 > --replication-factor 1 --partitions 1 --topic test > > How do I find out what group it belongs to? > > Thank you. > >
