Kaffe.Consumer.State (Kaffe v2.1.0)

View Source

Running state for the consumer.

  • message_handler - The module to call with each Kafka message
  • async - Kafka offset processing behavior