class Kafka::Producer

• Kafka::Producer
• Reference
• Object

Defined in:

kafka/producer.cr

Constructors

• .new(config : Kafka::Config)

Instance Method Summary

• #close
• #closing=(closing : Bool)
• #closing? : Bool
• #finalize
• #flush
• #produce(topic : String, payload : String, key : String = "", partition : Int32 = -1)

Macro Summary

• check_closed_connection!

Constructor Detail

Instance Method Detail

Macro Detail