class Kafka::Configuration

• Kafka::Configuration
• Reference
• Object

Defined in:

kafka/configuration.cr

Constructors

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

  Create configuration object.

Instance Method Summary

• #destroy

  Destroys the configuration object.

• #dump

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

• #dup : Configuration

  Creates a copy/duplicate of configuration object configuration.

• #get(name : String)

  Retrieve configuration value for property name.

• #set(name : String, value : String)

  Sets a configuration property.

• #set_consume_cb(&consume_cb : Message -> )

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

• #set_default_topic_conf

  Sets the default topic configuration to use for automatically subscribed topics (e.g., through pattern-matched topics).

• #set_dr_msg_cb(&dr_msg_cb : Producer, Message -> )

  Producer: Set delivery report callback in provided configuration object.

• #set_error_cb(&error_cb : Handle, LibC::Int, String -> )

  Set error callback in provided configuration object.

• #set_log_cb

  Set logger callback.

• #set_offset_commit_cb

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

• #set_opaque

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

• #set_open_cb

  Set open callback.

• #set_rebalance_cb(&rebalance_cb : Consumer, LibKafka::RespErrT, TopicPartitionList -> )

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

• #set_socket_cb

  Set socket callback.

• #set_stats_cb

  Set statistics callback in provided configuration object.

• #set_throttle_cb

  Set throttle callback.

• #to_unsafe : LibKafka::RdKafkaConfT

Constructor Detail

Instance Method Detail