ConsumerPerformance should not always reset to earliest offsets
Remove the explicit `seekToBeginning` on startup and instead rely on the consumer's auto offset reset strategy to set the initial position.
@@ -157,8 +157,6 @@ object ConsumerPerformance extends LazyLogging {
def onPartitionsRevoked(partitions: util.Collection[TopicPartition]) {
joinStart = System.currentTimeMillis
}})
- consumer.poll(0)
- consumer.seekToBeginning(Collections.emptyList())
// Now start the benchmark
val startMs = System.currentTimeMillis
