01-23-2019 12:26 PM
So, there were three issues. First off, you were correct in that the group was not attached to the partition. I'm sure it's obvious, but I'm new to kafka, so I'm not sure how the groups get associated with a partition. In my case the partition was already tied to a different group that I'm not familiar with. I'll need to do some research.
Second, my offsets were equal, so I had to reset my offset to 0.
Third, my java heap was too small.
Soon as I tweaked those, and adjusted to the proper group, as seen in the kafka-consumer-groups command, data is flowing. Now to figure out how the groups work.
Thanks so much for your help.
01-23-2019 02:16 PM
02-17-2019 09:00 PM - edited 02-17-2019 09:05 PM
Got the same problem here.
btw, log4j could not be modified(log4j.logger.org.apache.kafka=DEBUG) in the quickstart vm 5.13 cuz it is a read-only file, it doesn't allow me to save after the change. @pdvorak
Any other help would be highly appreciated! Thanks.