Module: Rdkafka

Defined in:

lib/rdkafka.rb,
lib/rdkafka/admin.rb,
lib/rdkafka/error.rb,
lib/rdkafka/config.rb,
lib/rdkafka/version.rb,
lib/rdkafka/bindings.rb,
lib/rdkafka/consumer.rb,
lib/rdkafka/defaults.rb,
lib/rdkafka/metadata.rb,
lib/rdkafka/producer.rb,
lib/rdkafka/callbacks.rb,
lib/rdkafka/helpers/time.rb,
lib/rdkafka/native_kafka.rb,
lib/rdkafka/helpers/oauth.rb,
lib/rdkafka/abstract_handle.rb,
lib/rdkafka/consumer/headers.rb,
lib/rdkafka/consumer/message.rb,
lib/rdkafka/consumer/partition.rb,
lib/rdkafka/admin/create_acl_handle.rb,
lib/rdkafka/admin/create_acl_report.rb,
lib/rdkafka/admin/delete_acl_handle.rb,
lib/rdkafka/admin/delete_acl_report.rb,
lib/rdkafka/admin/acl_binding_result.rb,
lib/rdkafka/producer/delivery_handle.rb,
lib/rdkafka/producer/delivery_report.rb,
lib/rdkafka/admin/create_topic_handle.rb,
lib/rdkafka/admin/create_topic_report.rb,
lib/rdkafka/admin/delete_topic_handle.rb,
lib/rdkafka/admin/delete_topic_report.rb,
lib/rdkafka/admin/describe_acl_handle.rb,
lib/rdkafka/admin/describe_acl_report.rb,
lib/rdkafka/admin/list_offsets_handle.rb,
lib/rdkafka/admin/list_offsets_report.rb,
lib/rdkafka/admin/delete_groups_handle.rb,
lib/rdkafka/admin/delete_groups_report.rb,
lib/rdkafka/admin/config_binding_result.rb,
lib/rdkafka/admin/describe_configs_handle.rb,
lib/rdkafka/admin/describe_configs_report.rb,
lib/rdkafka/consumer/topic_partition_list.rb,
lib/rdkafka/admin/create_partitions_handle.rb,
lib/rdkafka/admin/create_partitions_report.rb,
lib/rdkafka/producer/partitions_count_cache.rb,
lib/rdkafka/admin/config_resource_binding_result.rb,
lib/rdkafka/admin/incremental_alter_configs_handle.rb,
lib/rdkafka/admin/incremental_alter_configs_report.rb

Overview

Main Rdkafka namespace of this gem

Defined Under Namespace

Modules: Bindings, Callbacks, Defaults, Helpers Classes: AbstractHandle, Admin, BaseError, ClosedAdminError, ClosedConsumerError, ClosedInnerError, ClosedProducerError, Config, Consumer, LibraryLoadError, Metadata, NativeKafka, Opaque, Producer, RdkafkaError, RdkafkaTopicPartitionListError

Constant Summary

VERSION =

Current rdkafka-ruby gem version

"0.27.0"

LIBRDKAFKA_VERSION =

Target librdkafka version to be used

"2.14.0"

LIBRDKAFKA_SOURCE_SHA256 =

SHA256 hash of the librdkafka source tarball for verification

"c05c03ef00a13a8463fac3e8918c04843c416f11ced58c889d806a88ca92cf99"