class Kafka::TopicConfiguration

Defined in:

kafka/topic_configuration.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(conf : LibKafka::RdKafkaTopicConfT = LibKafka.topic_conf_new) #

Create topic configuration object.


[View source]

Instance Method Detail

def destroy #

Destroys the topic configuration object.


[View source]
def dup #

Creates a copy/duplicate of topic configuration object configuration.


[View source]
def set(name : String, value : String) #

Sets a single topic configuration value by property name.


[View source]
def to_unsafe : LibKafka::RdKafkaTopicConfT #

[View source]