Kaffe.Consumer.State (Kaffe v1.26.0) View Source

Running state for the consumer.

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