ject: [0.9.0.1] Having problems with commitAsync() not updating offsets
Hello,
I'm having trouble with commitAsync() not updating my partition offsets. I
pre-populate 1,000,000 strings on topic 'lowercaseStrings' across 4 partitions.
I check the offsets and they're fine--250K records/partition
Hello,
I'm having trouble with commitAsync() not updating my partition offsets. I
pre-populate 1,000,000 strings on topic 'lowercaseStrings' across 4 partitions.
I check the offsets and they're fine--250K records/partition.
Then I run some code that uses a single-thread with blocking queue to
