module

Kafka

Constants

VERSION = "0.1.0"

Class methods

err2name(err : LibKafka::RespErrT) : String

Returns the error code name (enum name).

Source
err2str(err : LibKafka::RespErrT) : String

Returns a human readable representation of a kafka error.

Source
get_debug_contexts

Retrieve supported debug contexts for use with the "debug" configuration property. Returns comma-separated list of available debugging contexts.

Source
get_err_descs

FIXME: only returning first errdesc Returns the full list of error codes.

Source
last_error

Returns the last error code generated by a legacy API call in the current thread.

Source
version

Returns the librdkafka version as integer.

Source
version_str

Returns the librdkafka version as string.

Source
wait_destroyed(timeout_ms = 1000) : LibC::Int

Wait for all rd_kafka_t objects to be destroyed.

Source

Instance methods

conf_properties_show

Prints a table to fp of all supported configuration properties, their default values as well as a description.

Source
errno

Returns the thread-local system errno.

Source
errno2err(errnox : LibC::Int) : LibKafka::RespErrT

Converts the system errno value errnox to a RespErrT error code upon failure from the following functions:

  • rd_kafka_topic_new()
  • rd_kafka_consume_start()
  • rd_kafka_consume_stop()
  • rd_kafka_consume()
  • rd_kafka_consume_batch()
  • rd_kafka_consume_callback()
  • rd_kafka_consume_queue()
  • rd_kafka_produce()
Source
thread_cnt

Retrieve the current number of threads in use by librdkafka.

Source

Nested types