class

Kafka::Consumer

Inherits Kafka::Client < Reference < Object

Constants

ERRLEN = 128

Constructors

new(config : Hash(String, String))
Source

Instance methods

close
Source
each(timeout = 250, &)
Source
poll(timeout_ms : Int32) : Message | Nil
Source
subscribe(*topics) : Error | Nil
Source