Kaffe.Consumer.State (Kaffe v1.25.0) View Source
Running state for the consumer.
message_handler
- The module to call with each Kafka messageasync
- Kafka offset processing behavior
Running state for the consumer.
message_handler
- The module to call with each Kafka messageasync
- Kafka offset processing behavior