RdkafkaBridges class

Constructors

RdkafkaBridges(DynamicLibrary _lib)

RdkafkaBridges.defaultLib()

factory

Properties

hashCode → int

The hash code for this object.

no setter, inherited

rd_kafka_committed → int Function(Pointer<rd_kafka_t> rk, Pointer<rd_kafka_topic_partition_list_t> partitions, int timeout_ms)

late, final

rd_kafka_conf_new → rd_kafka_conf_new_native_t

late, final

rd_kafka_conf_set → int Function(Pointer<rd_kafka_conf_t> conf, Pointer<Utf8> name, Pointer<Utf8> value, Pointer<Utf8> errstr, Pointer<Int32> errstr_size)

late, final

rd_kafka_destroy → void Function(Pointer<rd_kafka_t> rk)

late, final

rd_kafka_err2name → Pointer<Utf8> Function(int err)

late, final

rd_kafka_err2str → Pointer<Utf8> Function(int err)

late, final

rd_kafka_get_watermark_offsets → int Function(Pointer<rd_kafka_t> rk, Pointer<Utf8> topic, int partition, Pointer<Int64> low, Pointer<Int64> high)

late, final

rd_kafka_group_list_destroy → void Function(Pointer<rd_kafka_group_list>)

late, final

rd_kafka_list_groups → int Function(Pointer<rd_kafka_t> rk, Pointer<Utf8> group, Pointer<Pointer<rd_kafka_group_list>> grplistp, int timeout_ms)

late, final

rd_kafka_metadata → int Function(Pointer<rd_kafka_t> rk, int all_topics, Pointer<rd_kafka_topic_t> only_rkt, Pointer<Pointer<rd_kafka_metadata_t>> metadatap, int timeout_ms)

late, final

rd_kafka_new → Pointer<rd_kafka_t> Function(int type, Pointer<rd_kafka_conf_t> conf, Pointer<Utf8> errstr, Pointer<Int32> errstr_size)

late, final

rd_kafka_query_watermark_offsets → int Function(Pointer<rd_kafka_t> rk, Pointer<Utf8> topic, int partition, Pointer<Int64> low, Pointer<Int64> high, int timeout_ms)

late, final

rd_kafka_topic_conf_new → rd_kafka_topic_conf_new_native_t

late, final

rd_kafka_topic_conf_set → int Function(Pointer<rd_kafka_topic_conf_t> conf, Pointer<Utf8> name, Pointer<Utf8> value, Pointer<Utf8> errstr, Pointer<Int32> errstr_size)

late, final

rd_kafka_topic_destroy → void Function(Pointer<rd_kafka_topic_t> rkt)

late, final

rd_kafka_topic_name → rd_kafka_topic_name_native_t

late, final

rd_kafka_topic_new → rd_kafka_topic_new_native_t

late, final

rd_kafka_topic_partition_list_add → Pointer<rd_kafka_topic_partition_t> Function(Pointer<rd_kafka_topic_partition_list_t> rkparlist, Pointer<Utf8> topic, int partition)

late, final

rd_kafka_topic_partition_list_add_range → void Function(Pointer<rd_kafka_topic_partition_list_t> rkparlist, Pointer<Utf8> topic, int start, int end)

late, final

rd_kafka_topic_partition_list_del → int Function(Pointer<rd_kafka_topic_partition_list_t> rkparlist, Pointer<Utf8> topic, int partition)

late, final

rd_kafka_topic_partition_list_destroy → void Function(Pointer<rd_kafka_topic_partition_list_t> rkparlist)

late, final

rd_kafka_topic_partition_list_new → Pointer<rd_kafka_topic_partition_list_t> Function(int size)

late, final

rd_kafka_topic_partition_list_set_offset → int Function(Pointer<rd_kafka_topic_partition_list_t> rkparlist, Pointer<Utf8> topic, int partition, int offset)

late, final

rd_kafka_version → int Function()

late, final

rd_kafka_version_str → rd_kafka_version_str_native_t

late, final

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited

Static Properties

instance → RdkafkaBridges

no setter