class Kafka::Config
- Kafka::Config
- Reference
- Object
Defined in:
kafka/config.crClass Method Summary
-
.build(properties : Hash(String, String)) : LibRdKafka::ConfHandle
Returns a librdkafka configuration object with the given properties set.
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.