Does increasing PartitionFetchInfo.fetchSize help?
Speaking of Kafka API, it looks like throwing exception would be less
confusing if fetchSize is not enough to get at least one message at
requested offset.
2015-04-28 21:12 GMT+03:00 Laran Evans :
> I’ve got a simple consumer. According to GetOf
I’ve got a simple consumer. According to GetOffsetShell my offset is 209418.
But the SimpleConsumer doesn’t get any messages past offset 123146. It just
won’t pull down any messages after that offset. If I send more messages onto
the topic it still won’t pull them down. Though the offset does in
