Member since
01-23-2019
3
Posts
0
Kudos Received
0
Solutions
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.
... View more
01-23-2019
11:16 AM
Great, thank you. I'll take a look at both paths to see if we can narrow down where the issue is occurring. I'm very confident it's a consumer config issue, but I thought the bare bones config examples on the web would just work, even if not efficiently. Thanks again...I'll provide an update on how this goes.
... View more
01-23-2019
10:45 AM
Sadly I have no new info to provide insight into this issue...but also wanted to callout that we are seeing the same thing on our side. No errors, just no data movement on the kafka-source -> flume side.
... View more