Code description
This code snippet reads data from topic's beginning offset by utilizing seek_to_beginning()
API. This will sets each partitions subscribed by the consumers to fetch records from the earliest available offsets.
Example output:
polling...
Kontext message 1
Kontext message 2
Kontext message 3
Kontext message 4
Kontext message 5
New kontext events~!!
New events!
polling...
polling...