Module consumer

Module consumer 

Source
Expand description

Consumer: poll messages from assigned partitions, commit offsets, seek.

Structs§

Consumer
A consumer that reads from specific partitions of a topic.

Enums§

SeekPolicy
Seek policy for initializing consumer position.