class

Kafka::Configuration

Inherits Reference < Object

Constructors

new(conf : LibKafka::RdKafkaConfT = LibKafka.conf_new)

Create configuration object.

Source

Instance methods

destroy

Destroys the configuration object.

Source
dump

Dump the configuration properties and values of configuration to an array with "key", "value" pairs.

Source
dup

Creates a copy/duplicate of configuration object configuration.

Source
get(name : String)

Retrieve configuration value for property name.

Source
set(name : String, value : String)

Sets a configuration property.

Source
set_consume_cb

Consumer: Set consume callback for use with rd_kafka_consumer_poll().

Source
set_default_topic_conf

Sets the default topic configuration to use for automatically subscribed topics (e.g., through pattern-matched topics). The topic configuration object is not usable after this call.

Source
set_dr_msg_cb

Producer: Set delivery report callback in provided configuration object.

Source
set_error_cb

Set error callback in provided configuration object.

Source
set_log_cb

Set logger callback.

Source
set_offset_commit_cb

Consumer: Set offset commit callback for use with consumer groups.

Source
set_opaque

Sets the application's opaque pointer that will be passed to callbacks.

Source
set_open_cb

Set open callback.

Source
set_rebalance_cb

Consumer: Set rebalance callback for use with coordinated consumer group balancing.

Source
set_socket_cb

Set socket callback.

Source
set_stats_cb

Set statistics callback in provided configuration object.

Source
set_throttle_cb

Set throttle callback.

Source
to_unsafe
Source