KafkaConsumer.this

Creates a KafkaConsumer.

The \p conf object must have \c group.id set to the consumer group to join.

Use close() to shut down the consumer.

class KafkaConsumer
this
(
GlobalConf conf
)

See Also

RebalanceCb CONFIGURATION.md for \c group.id, \c session.timeout.ms, \c partition.assignment.strategy, etc.

Meta