class Kafka::Config

Defined in:

kafka/config.cr

Class Method Summary

Class Method Detail

def self.build(properties : Hash(String, String)) : LibRdKafka::ConfHandle #

Returns a librdkafka configuration object with the given properties set.

Raises a Kafka::Config::InvalidConfigException when setting config fails. Calls the rd_kafka_conf_new and rd_kafka_conf_set C functions.


[View source]