Hi

In my consumer app, in order to start consuming records from the beginning
of all partitions of a given Kafka topic, I first have to issue a poll to
make sure partitions are assigned to my consumer:

consumer.poll(1000);
consumer.seekToBeginning(consumer.assignment());

Is there an alternative approach available to assign partitions to the
consumer that doesn't require issuing an initial poll?

Best regards,
Behrang Saeedzadeh

Reply via email to