Consumer.start

Start consuming messages for topic and \p partition at offset \p offset which may either be a proper offset (0..N) or one of the the special offsets: \p OFFSET_BEGINNING or \p OFFSET_END.

rdkafka will attempt to keep \p queued.min.messages (config property) messages in the local queue by repeatedly fetching batches of messages from the broker until the threshold is reached.

The application shall use one of the \p ...consume*() functions to consume messages from the local queue, each kafka message being represented as a Message object.

\p ...start() must not be called multiple times for the same topic and partition without stopping consumption first with \p ...stop().

an ErrorCode to indicate success or failure.

class Consumer
nothrow @nogc static
start
(
Topic topic
,,
long offset
,
Queue queue
)

Meta