Your consumer "might" belong to a consumer group. Just commit offsets to that consumer groups/topic/partition and it will work.
That said - if you want to figure out the consumers groups that exists you have to look in zookeeper. There is no kafka API to get or create them. In the java client it is done internally by a zookeeper connector the following paths seems to exists for all consumer groups /consumers/"consumer_group"/offsets /consumers/"consumer_group"/owners /svante 2015-03-31 15:10 GMT+02:00 James King <jakwebin...@gmail.com>: > 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. >
