@brief Stop consuming messages for topic \p rkt and \p partition, purging
all messages currently in the local queue.
NOTE: To enforce synchronisation this call will block until the internal
fetcher has terminated and offsets are committed to configured
storage method.
The application needs to be stop all consumers before calling
rd_kafka_destroy() on the main object handle.
@brief Stop consuming messages for topic \p rkt and \p partition, purging all messages currently in the local queue.
NOTE: To enforce synchronisation this call will block until the internal fetcher has terminated and offsets are committed to configured storage method.
The application needs to be stop all consumers before calling rd_kafka_destroy() on the main object handle.
@returns 0 on success or -1 on error (see errno).