tree 99a423af3814c3e74136e715a320b4b36937dc5b
parent 67c5c3e28c879a6bbb3a1a7d5ffdfcec3c3f3720
author Antonio Barone <syntonyze@gmail.com> 1614717530 +0100
committer Antonio Barone <syntonyze@gmail.com> 1614875751 +0100

Fix kafka-events replay messages feature

When requesting to reset the offset and consume messages from the
beginning, the subscriber has to wait first for the assignment of
partitions.

Failing to do so will cause the subscriber to consume zero records,
since no partitions have yet been assigned.

Make an explicit poll() call before the seekToBeginning() to ensure that
the consumer heartbeat is sent to kafka and thus a partition is
assigned.

Bug: Issue 14136
Change-Id: Ibc6a66507ebfc9bb6c67df9e576114bed8973e74