class

Kafka::Producer

Inherits Reference < Object

Constructors

new(config : Hash(String, String))

creates a new kafka handle using provided config. Throws exception on error

Source

Instance methods

finalize
Source
flush(timeout = 1000)
Source
poll(timeout = 500)
Source
produce(topic : String, key : Bytes, payload : Bytes, timestamp : Int64)
Source
produce(topic : String, key : Bytes, payload : Bytes)
Source
produce0(topic : String, msg : Message)
Source
produce_batch(topic : String, batch : Array(NamedTuple(key: Array(UInt8), msg: Array(UInt8))))
Source