class Kafka::Consumer

• Kafka::Consumer
• Reference
• Object

Defined in:

kafka/consumer.cr

Constructors

• .new(config : Kafka::Config)

Instance Method Summary

• #close
• #cluster_id
• #each(&)
• #each_batch(size : Int32, timeout_ms : Int32, &)
• #finalize
• #member_id
• #poll(timeout_ms : Int32)
• #seek(message : Kafka::Message)
• #store_offset(message)
• #subscribe(topics : Array(String))
• #unsubscribe

Macro Summary

• check_closed_connection!

Constructor Detail

Instance Method Detail

Macro Detail