LibRdKafka class
Methods
accept (int arg0 , Pointer <sockaddr arg1 , Pointer <socklen_t arg2 → int
asprintf (Pointer <Pointer <Char arg0 , Pointer <Char arg1 → int
bind (int arg0 , Pointer <sockaddr arg1 , int arg2 → int
clearerr (Pointer <FILE arg0 → void
connect (int arg0 , Pointer <sockaddr arg1 , int arg2 → int
connectx (int arg0 , Pointer <sa_endpoints_t arg1 , int arg2 , int arg3 , Pointer <iovec arg4 , int arg5 , Pointer <Size arg6 , Pointer <sae_connid_t arg7 → int
ctermid (Pointer <Char arg0 → Pointer <Char
ctermid_r (Pointer <Char arg0 → Pointer <Char
disconnectx (int arg0 , int arg1 , int arg2 → int
dprintf (int arg0 , Pointer <Char arg1 → int
fclose (Pointer <FILE arg0 → int
fdopen (int arg0 , Pointer <Char arg1 → Pointer <FILE
feof (Pointer <FILE arg0 → int
ferror (Pointer <FILE arg0 → int
fflush (Pointer <FILE arg0 → int
fgetc (Pointer <FILE arg0 → int
fgetln (Pointer <FILE arg0 , Pointer <Size arg1 → Pointer <Char
fgetpos (Pointer <FILE arg0 , Pointer <fpos_t arg1 → int
fgets (Pointer <Char arg0 , int arg1 , Pointer <FILE arg2 → Pointer <Char
fileno (Pointer <FILE arg0 → int
flockfile (Pointer <FILE arg0 → void
fmemopen (Pointer <Void __buf , int __size , Pointer <Char __mode → Pointer <FILE
fmtcheck (Pointer <Char arg0 , Pointer <Char arg1 → Pointer <Char
fopen (Pointer <Char __filename , Pointer <Char __mode → Pointer <FILE
fprintf (Pointer <FILE arg0 , Pointer <Char arg1 → int
fpurge (Pointer <FILE arg0 → int
fputc (int arg0 , Pointer <FILE arg1 → int
fputs (Pointer <Char arg0 , Pointer <FILE arg1 → int
fread (Pointer <Void __ptr , int __size , int __nitems , Pointer <FILE __stream → int
freopen (Pointer <Char arg0 , Pointer <Char arg1 , Pointer <FILE arg2 → Pointer <FILE
fscanf (Pointer <FILE arg0 , Pointer <Char arg1 → int
fseek (Pointer <FILE arg0 , int arg1 , int arg2 → int
fseeko (Pointer <FILE __stream , int __offset , int __whence → int
fsetpos (Pointer <FILE arg0 , Pointer <fpos_t arg1 → int
ftell (Pointer <FILE arg0 → int
ftello (Pointer <FILE __stream → int
ftrylockfile (Pointer <FILE arg0 → int
funlockfile (Pointer <FILE arg0 → void
funopen (Pointer <Void arg0 , Pointer <NativeFunction <Int Function(Pointer <Void Pointer <Char Int arg1 , Pointer <NativeFunction <Int Function(Pointer <Void Pointer <Char Int arg2 , Pointer <NativeFunction <fpos_t Function(Pointer <Void fpos_t Int arg3 , Pointer <NativeFunction <Int Function(Pointer <Void arg4 → Pointer <FILE
fwrite (Pointer <Void __ptr , int __size , int __nitems , Pointer <FILE __stream → int
getc (Pointer <FILE arg0 → int
getc_unlocked (Pointer <FILE arg0 → int
getchar ()
→ int
getchar_unlocked ()
→ int
getdelim (Pointer <Pointer <Char __linep , Pointer <Size __linecapp , int __delimiter , Pointer <FILE __stream → int
getline (Pointer <Pointer <Char __linep , Pointer <Size __linecapp , Pointer <FILE __stream → int
getpeername (int arg0 , Pointer <sockaddr arg1 , Pointer <socklen_t arg2 → int
gets (Pointer <Char arg0 → Pointer <Char
getsockname (int arg0 , Pointer <sockaddr arg1 , Pointer <socklen_t arg2 → int
getsockopt (int arg0 , int arg1 , int arg2 , Pointer <Void arg3 , Pointer <socklen_t arg4 → int
getw (Pointer <FILE arg0 → int
imaxabs (int j → int
imaxdiv (int __numer , int __denom → imaxdiv_t
listen (int arg0 , int arg1 → int
noSuchMethod (Invocation invocation → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
open_memstream (Pointer <Pointer <Char __bufp , Pointer <Size __sizep → Pointer <FILE
pclose (Pointer <FILE arg0 → int
perror (Pointer <Char arg0 → void
pfctlinput (int arg0 , Pointer <sockaddr arg1 → void
popen (Pointer <Char arg0 , Pointer <Char arg1 → Pointer <FILE
printf (Pointer <Char arg0 → int
putc (int arg0 , Pointer <FILE arg1 → int
putc_unlocked (int arg0 , Pointer <FILE arg1 → int
putchar (int arg0 → int
putchar_unlocked (int arg0 → int
puts (Pointer <Char arg0 → int
putw (int arg0 , Pointer <FILE arg1 → int
rd_kafka_abort_transaction (Pointer <rd_kafka_t rk , int timeout_ms → Pointer <rd_kafka_error_t
@brief Aborts the ongoing transaction.
rd_kafka_acl_result_error (Pointer <rd_kafka_acl_result_t aclres → Pointer <rd_kafka_error_t
@returns the error object for the given acl result, or NULL on success.
rd_kafka_AclBinding_destroy (Pointer <rd_kafka_AclBinding_t acl_binding → void
@brief Destroy and free an AclBinding object previously created with
rd_kafka_AclBinding_new()
rd_kafka_AclBinding_destroy_array (Pointer <Pointer <rd_kafka_AclBinding_t acl_bindings , int acl_bindings_cnt → void
@brief Helper function to destroy all AclBinding objects in
the \p acl_bindings array (of \p acl_bindings_cnt elements).
The array itself is not freed.
rd_kafka_AclBinding_error (Pointer <rd_kafka_AclBinding_t acl → Pointer <rd_kafka_error_t
@returns the error object for the given acl binding, or NULL on success.
rd_kafka_AclBinding_host (Pointer <rd_kafka_AclBinding_t acl → Pointer <Char
@returns the host for the given acl binding.
rd_kafka_AclBinding_name (Pointer <rd_kafka_AclBinding_t acl → Pointer <Char
@returns the resource name for the given acl binding.
rd_kafka_AclBinding_new (int restype , Pointer <Char name , int resource_pattern_type , Pointer <Char principal , Pointer <Char host , int operation , int permission_type , Pointer <Char errstr , int errstr_size → Pointer <rd_kafka_AclBinding_t
@brief Create a new AclBinding object. This object is later passed to
rd_kafka_CreateAcls().
rd_kafka_AclBinding_operation (Pointer <rd_kafka_AclBinding_t acl → int
@returns the acl operation for the given acl binding.
rd_kafka_AclBinding_permission_type (Pointer <rd_kafka_AclBinding_t acl → int
@returns the permission type for the given acl binding.
rd_kafka_AclBinding_principal (Pointer <rd_kafka_AclBinding_t acl → Pointer <Char
@returns the principal for the given acl binding.
rd_kafka_AclBinding_resource_pattern_type (Pointer <rd_kafka_AclBinding_t acl → int
@returns the resource pattern type for the given acl binding.
rd_kafka_AclBinding_restype (Pointer <rd_kafka_AclBinding_t acl → int
@returns the resource type for the given acl binding.
rd_kafka_AclBindingFilter_new (int restype , Pointer <Char name , int resource_pattern_type , Pointer <Char principal , Pointer <Char host , int operation , int permission_type , Pointer <Char errstr , int errstr_size → Pointer <rd_kafka_AclBindingFilter_t
@brief Create a new AclBindingFilter object. This object is later passed to
rd_kafka_DescribeAcls() or
rd_kafka_DeletesAcls() in order to filter
the acls to retrieve or to delete.
Use the same rd_kafka_AclBinding functions to query or destroy it.
rd_kafka_AclOperation_name (int acl_operation → Pointer <Char
@returns a string representation of the \p acl_operation
rd_kafka_AclPermissionType_name (int acl_permission_type → Pointer <Char
@returns a string representation of the \p acl_permission_type
rd_kafka_AdminOptions_destroy (Pointer <rd_kafka_AdminOptions_t options → void
@brief Destroy a AdminOptions object.
rd_kafka_AdminOptions_new (Pointer <rd_kafka_t rk , int for_api → Pointer <rd_kafka_AdminOptions_t
@brief Create a new AdminOptions object.
rd_kafka_AdminOptions_set_broker (Pointer <rd_kafka_AdminOptions_t options , int broker_id , Pointer <Char errstr , int errstr_size → int
@brief Override what broker the Admin request will be sent to.
rd_kafka_AdminOptions_set_include_authorized_operations (Pointer <rd_kafka_AdminOptions_t options , int true_or_false → Pointer <rd_kafka_error_t
@brief Whether broker should return authorized operations for the given
resource in the DescribeConsumerGroups, DescribeTopics, or
DescribeCluster calls.
rd_kafka_AdminOptions_set_isolation_level (Pointer <rd_kafka_AdminOptions_t options , int value → Pointer <rd_kafka_error_t
@brief Set Isolation Level to an allowed rd_kafka_IsolationLevel_t value.
rd_kafka_AdminOptions_set_match_consumer_group_states (Pointer <rd_kafka_AdminOptions_t options , Pointer <Int32 consumer_group_states , int consumer_group_states_cnt → Pointer <rd_kafka_error_t
@brief Set consumer groups states to query for.
rd_kafka_AdminOptions_set_match_consumer_group_types (Pointer <rd_kafka_AdminOptions_t options , Pointer <Int32 consumer_group_types , int consumer_group_types_cnt → Pointer <rd_kafka_error_t
@brief Set consumer groups types to query for.
rd_kafka_AdminOptions_set_opaque (Pointer <rd_kafka_AdminOptions_t options , Pointer <Void ev_opaque → void
@brief Set application opaque value that can be extracted from the
result event using rd_kafka_event_opaque()
rd_kafka_AdminOptions_set_operation_timeout (Pointer <rd_kafka_AdminOptions_t options , int timeout_ms , Pointer <Char errstr , int errstr_size → int
@brief Sets the broker's operation timeout, such as the timeout for
CreateTopics to complete the creation of topics on the controller
before returning a result to the application.
rd_kafka_AdminOptions_set_request_timeout (Pointer <rd_kafka_AdminOptions_t options , int timeout_ms , Pointer <Char errstr , int errstr_size → int
@brief Sets the overall request timeout, including broker lookup,
request transmission, operation time on broker, and response.
rd_kafka_AdminOptions_set_require_stable_offsets (Pointer <rd_kafka_AdminOptions_t options , int true_or_false → Pointer <rd_kafka_error_t
@brief Whether broker should return stable offsets
(transaction-committed).
rd_kafka_AdminOptions_set_validate_only (Pointer <rd_kafka_AdminOptions_t options , int true_or_false , Pointer <Char errstr , int errstr_size → int
@brief Tell broker to only validate the request, without performing
the requested operation (create topics, etc).
rd_kafka_AlterConfigs (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_ConfigResource_t configs , int config_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Update the configuration for the specified resources.
Updates are not transactional so they may succeed for a subset
of the provided resources while the others fail.
The configuration for a particular resource is updated atomically,
replacing values using the provided ConfigEntrys and reverting
unspecified ConfigEntrys to their default values.
rd_kafka_AlterConfigs_result_resources (Pointer <rd_kafka_AlterConfigs_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_ConfigResource_t
@brief Get an array of resource results from a AlterConfigs result.
rd_kafka_AlterConsumerGroupOffsets (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_AlterConsumerGroupOffsets_t alter_grpoffsets , int alter_grpoffsets_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Alter committed offsets for a set of partitions in a consumer
group. This will succeed at the partition level only if the group
is not actively subscribed to the corresponding topic.
rd_kafka_AlterConsumerGroupOffsets_destroy (Pointer <rd_kafka_AlterConsumerGroupOffsets_t alter_grpoffsets → void
@brief Destroy and free a AlterConsumerGroupOffsets object previously
created with rd_kafka_AlterConsumerGroupOffsets_new()
rd_kafka_AlterConsumerGroupOffsets_destroy_array (Pointer <Pointer <rd_kafka_AlterConsumerGroupOffsets_t alter_grpoffsets , int alter_grpoffset_cnt → void
@brief Helper function to destroy all AlterConsumerGroupOffsets objects in
the \p alter_grpoffsets array (of \p alter_grpoffsets_cnt elements).
The array itself is not freed.
rd_kafka_AlterConsumerGroupOffsets_new (Pointer <Char group_id , Pointer <rd_kafka_topic_partition_list_t partitions → Pointer <rd_kafka_AlterConsumerGroupOffsets_t
@brief Create a new AlterConsumerGroupOffsets object.
This object is later passed to rd_kafka_AlterConsumerGroupOffsets().
rd_kafka_AlterConsumerGroupOffsets_result_groups (Pointer <rd_kafka_AlterConsumerGroupOffsets_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_group_result_t
@brief Get an array of results from a AlterConsumerGroupOffsets result.
rd_kafka_AlterUserScramCredentials (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_UserScramCredentialAlteration_t alterations , int alteration_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Alter SASL/SCRAM credentials.
This operation is supported by brokers with version 2.7.0 or higher.
rd_kafka_AlterUserScramCredentials_result_response_error (Pointer <rd_kafka_AlterUserScramCredentials_result_response_t response → Pointer <rd_kafka_error_t
@brief Returns the error of a
rd_kafka_AlterUserScramCredentials_result_response.
rd_kafka_AlterUserScramCredentials_result_response_user (Pointer <rd_kafka_AlterUserScramCredentials_result_response_t response → Pointer <Char
@brief Returns the username for a
rd_kafka_AlterUserScramCredentials_result_response.
rd_kafka_AlterUserScramCredentials_result_responses (Pointer <rd_kafka_AlterUserScramCredentials_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_AlterUserScramCredentials_result_response_t
@brief Get an array of responses from a AlterUserScramCredentials result.
rd_kafka_assign (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t partitions → int
@brief Atomic assignment of partitions to consume.
rd_kafka_assignment (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_topic_partition_list_t partitions → int
@brief Returns the current partition assignment as set by rd_kafka_assign()
or rd_kafka_incremental_assign().
rd_kafka_assignment_lost (Pointer <rd_kafka_t rk → int
@brief Check whether the consumer considers the current assignment to
have been lost involuntarily. This method is only applicable for
use with a high level subscribing consumer. Assignments are revoked
immediately when determined to have been lost, so this method
is only useful when reacting to a RD_KAFKA_EVENT_REBALANCE event
or from within a rebalance_cb. Partitions that have been lost may
already be owned by other members in the group and therefore
commiting offsets, for example, may fail.
rd_kafka_begin_transaction (Pointer <rd_kafka_t rk → Pointer <rd_kafka_error_t
@brief Begin a new transaction.
rd_kafka_brokers_add (Pointer <rd_kafka_t rk , Pointer <Char brokerlist → int
@brief Adds one or more brokers to the kafka handle's list of initial
bootstrap brokers.
rd_kafka_clusterid (Pointer <rd_kafka_t rk , int timeout_ms → Pointer <Char
@brief Returns the ClusterId as reported in broker metadata.
rd_kafka_commit (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t offsets , int async1 → int
@brief Commit offsets on broker for the provided list of partitions.
rd_kafka_commit_message (Pointer <rd_kafka_t rk , Pointer <rd_kafka_message_t rkmessage , int async1 → int
@brief Commit message's offset on broker for the message's partition.
The committed offset is the message's offset + 1.
rd_kafka_commit_queue (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t offsets , Pointer <rd_kafka_queue_t rkqu , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Int32 err , Pointer <rd_kafka_topic_partition_list_t offsets , Pointer <Void commit_opaque cb , Pointer <Void commit_opaque → int
@brief Commit offsets on broker for the provided list of partitions.
rd_kafka_commit_transaction (Pointer <rd_kafka_t rk , int timeout_ms → Pointer <rd_kafka_error_t
@brief Commit the current transaction (as started with
rd_kafka_begin_transaction()).
rd_kafka_committed (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t partitions , int timeout_ms → int
@brief Retrieve committed offsets for topics+partitions.
rd_kafka_conf (Pointer <rd_kafka_t rk → Pointer <rd_kafka_conf_t
@returns the configuration object used by an rd_kafka_t instance.
For use with rd_kafka_conf_get(), et.al., to extract configuration
properties from a running client.
rd_kafka_conf_destroy (Pointer <rd_kafka_conf_t conf → void
@brief Destroys a conf object.
rd_kafka_conf_dump (Pointer <rd_kafka_conf_t conf , Pointer <Size cntp → Pointer <Pointer <Char
@brief Dump the configuration properties and values of \p conf to an array
with "key", "value" pairs.
rd_kafka_conf_dump_free (Pointer <Pointer <Char arr , int cnt → void
@brief Frees a configuration dump returned from rd_kafka_conf_dump() or
`rd_kafka_topic_conf_dump().
rd_kafka_conf_dup (Pointer <rd_kafka_conf_t conf → Pointer <rd_kafka_conf_t
@brief Creates a copy/duplicate of configuration object \p conf
rd_kafka_conf_dup_filter (Pointer <rd_kafka_conf_t conf , int filter_cnt , Pointer <Pointer <Char filter → Pointer <rd_kafka_conf_t
@brief Same as rd_kafka_conf_dup() but with an array of property name
prefixes to filter out (ignore) when copying.
rd_kafka_conf_enable_sasl_queue (Pointer <rd_kafka_conf_t conf , int enable → void
@brief Enable/disable creation of a queue specific to SASL events
and callbacks.
rd_kafka_conf_get (Pointer <rd_kafka_conf_t conf , Pointer <Char name , Pointer <Char dest , Pointer <Size dest_size → int
@brief Retrieve configuration value for property \p name.
rd_kafka_conf_get_default_topic_conf (Pointer <rd_kafka_conf_t conf → Pointer <rd_kafka_topic_conf_t
@brief Gets the default topic configuration as previously set with
rd_kafka_conf_set_default_topic_conf() or that was implicitly created
by configuring a topic-level property on the global \p conf object.
rd_kafka_conf_interceptor_add_on_conf_destroy (Pointer <rd_kafka_conf_t conf , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_conf_destroy_t on_conf_destroy , Pointer <Void ic_opaque → int
@brief Append an on_conf_destroy() interceptor.
rd_kafka_conf_interceptor_add_on_conf_dup (Pointer <rd_kafka_conf_t conf , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_conf_dup_t on_conf_dup , Pointer <Void ic_opaque → int
@brief Append an on_conf_dup() interceptor.
rd_kafka_conf_interceptor_add_on_conf_set (Pointer <rd_kafka_conf_t conf , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_conf_set_t on_conf_set , Pointer <Void ic_opaque → int
@brief Append an on_conf_set() interceptor.
rd_kafka_conf_interceptor_add_on_new (Pointer <rd_kafka_conf_t conf , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_new_t on_new , Pointer <Void ic_opaque → int
@brief Append an on_new() interceptor.
rd_kafka_conf_new ()
→ Pointer <rd_kafka_conf_t
@brief Create configuration object.
rd_kafka_conf_properties_show (Pointer <FILE fp → void
@brief Prints a table to \p fp of all supported configuration properties,
their default values as well as a description.
rd_kafka_conf_set (Pointer <rd_kafka_conf_t conf , Pointer <Char name , Pointer <Char value , Pointer <Char errstr , int errstr_size → int
@brief Sets a configuration property.
rd_kafka_conf_set_background_event_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Pointer <rd_kafka_event_t rkev , Pointer <Void opaque event_cb → void
@brief Generic event callback to be used with the event API to trigger
callbacks for \c rd_kafka_event_t objects from a background
thread serving the background queue.
rd_kafka_conf_set_closesocket_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Int Function(Int sockfd , Pointer <Void opaque closesocket_cb → void
@brief Set close socket callback.
rd_kafka_conf_set_connect_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Int Function(Int sockfd , Pointer <sockaddr addr , Int addrlen , Pointer <Char id , Pointer <Void opaque connect_cb → void
@brief Set connect callback.
rd_kafka_conf_set_consume_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_message_t rkmessage , Pointer <Void opaque consume_cb → void
@brief \b Consumer: Set consume callback for use with
rd_kafka_consumer_poll()
rd_kafka_conf_set_default_topic_conf (Pointer <rd_kafka_conf_t conf , Pointer <rd_kafka_topic_conf_t tconf → void
@brief Sets the default topic configuration to use for automatically
subscribed topics (e.g., through pattern-matched topics).
The topic config object is not usable after this call.
rd_kafka_conf_set_dr_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Pointer <Void payload , Size len , Int32 err , Pointer <Void opaque , Pointer <Void msg_opaque dr_cb → void
@deprecated See rd_kafka_conf_set_dr_msg_cb()
rd_kafka_conf_set_dr_msg_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Pointer <rd_kafka_message_t rkmessage , Pointer <Void opaque dr_msg_cb → void
@brief \b Producer: Set delivery report callback in provided \p conf object.
rd_kafka_conf_set_engine_callback_data (Pointer <rd_kafka_conf_t conf , Pointer <Void callback_data → void
@brief Set callback_data for OpenSSL engine.
rd_kafka_conf_set_error_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Int err , Pointer <Char reason , Pointer <Void opaque error_cb → void
@brief Set error callback in provided conf object.
rd_kafka_conf_set_events (Pointer <rd_kafka_conf_t conf , int events → void
@brief Enable event sourcing.
\p events is a bitmask of \c RD_KAFKA_EVENT_* of events to enable
for consumption by rd_kafka_queue_poll().
rd_kafka_conf_set_log_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Int level , Pointer <Char fac , Pointer <Char buf log_cb → void
@brief Set logger callback.
rd_kafka_conf_set_oauthbearer_token_refresh_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Pointer <Char oauthbearer_config , Pointer <Void opaque oauthbearer_token_refresh_cb → void
@brief Set SASL/OAUTHBEARER token refresh callback in provided conf object.
rd_kafka_conf_set_offset_commit_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Int32 err , Pointer <rd_kafka_topic_partition_list_t offsets , Pointer <Void opaque offset_commit_cb → void
@brief \b Consumer: Set offset commit callback for use with consumer groups.
rd_kafka_conf_set_opaque (Pointer <rd_kafka_conf_t conf , Pointer <Void opaque → void
@brief Sets the application's opaque pointer that will be passed to callbacks
rd_kafka_conf_set_open_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Int Function(Pointer <Char pathname , Int flags , mode_t mode , Pointer <Void opaque open_cb → void
@brief Set open callback.
rd_kafka_conf_set_rebalance_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Int32 err , Pointer <rd_kafka_topic_partition_list_t partitions , Pointer <Void opaque rebalance_cb → void
@brief \b Consumer: Set rebalance callback for use with
coordinated consumer group balancing.
rd_kafka_conf_set_resolve_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Int Function(Pointer <Char node , Pointer <Char service , Pointer <addrinfo hints , Pointer <Pointer <addrinfo res , Pointer <Void opaque resolve_cb → void
@brief Set address resolution callback.
rd_kafka_conf_set_socket_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Int Function(Int domain , Int type , Int protocol , Pointer <Void opaque socket_cb → void
@brief Set socket callback.
rd_kafka_conf_set_ssl_cert (Pointer <rd_kafka_conf_t conf , int cert_type , int cert_enc , Pointer <Void buffer , int size , Pointer <Char errstr , int errstr_size → int
@brief Set certificate/key \p cert_type from the \p cert_enc encoded
memory at \p buffer of \p size bytes.
rd_kafka_conf_set_ssl_cert_verify_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Int Function(Pointer <rd_kafka_t rk , Pointer <Char broker_name , Int32 broker_id , Pointer <Int x509_error , Int depth , Pointer <Char buf , Size size , Pointer <Char errstr , Size errstr_size , Pointer <Void opaque ssl_cert_verify_cb → int
@brief Sets the verification callback of the broker certificate
rd_kafka_conf_set_stats_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Int Function(Pointer <rd_kafka_t rk , Pointer <Char json , Size json_len , Pointer <Void opaque stats_cb → void
@brief Set statistics callback in provided conf object.
rd_kafka_conf_set_throttle_cb (Pointer <rd_kafka_conf_t conf , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Pointer <Char broker_name , Int32 broker_id , Int throttle_time_ms , Pointer <Void opaque throttle_cb → void
@brief Set throttle callback.
rd_kafka_ConfigEntry_is_default (Pointer <rd_kafka_ConfigEntry_t entry → int
@returns 1 if the config property is set to its default value on the broker,
else 0.
@remark Shall only be used on a DescribeConfigs result, otherwise returns -1.
rd_kafka_ConfigEntry_is_read_only (Pointer <rd_kafka_ConfigEntry_t entry → int
@returns 1 if the config property is read-only on the broker, else 0.
@remark Shall only be used on a DescribeConfigs result, otherwise returns -1.
rd_kafka_ConfigEntry_is_sensitive (Pointer <rd_kafka_ConfigEntry_t entry → int
@returns 1 if the config property contains sensitive information (such as
security configuration), else 0.
@remark An application should take care not to include the value of
sensitive configuration entries in its output.
@remark Shall only be used on a DescribeConfigs result, otherwise returns -1.
rd_kafka_ConfigEntry_is_synonym (Pointer <rd_kafka_ConfigEntry_t entry → int
@returns 1 if this entry is a synonym, else 0.
rd_kafka_ConfigEntry_name (Pointer <rd_kafka_ConfigEntry_t entry → Pointer <Char
@returns the configuration property name
rd_kafka_ConfigEntry_source (Pointer <rd_kafka_ConfigEntry_t entry → int
@returns the config source.
rd_kafka_ConfigEntry_synonyms (Pointer <rd_kafka_ConfigEntry_t entry , Pointer <Size cntp → Pointer <Pointer <rd_kafka_ConfigEntry_t
@returns the synonym config entry array.
rd_kafka_ConfigEntry_value (Pointer <rd_kafka_ConfigEntry_t entry → Pointer <Char
@returns the configuration value, may be NULL for sensitive or unset
properties.
rd_kafka_ConfigResource_add_incremental_config (Pointer <rd_kafka_ConfigResource_t config , Pointer <Char name , int op_type , Pointer <Char value → Pointer <rd_kafka_error_t
@brief Add the value of the configuration entry for a subsequent
incremental alter config operation. APPEND and SUBTRACT are
possible for list-type configuration entries only.
rd_kafka_ConfigResource_configs (Pointer <rd_kafka_ConfigResource_t config , Pointer <Size cntp → Pointer <Pointer <rd_kafka_ConfigEntry_t
@brief Get an array of config entries from a ConfigResource object.
rd_kafka_ConfigResource_destroy (Pointer <rd_kafka_ConfigResource_t config → void
@brief Destroy and free a ConfigResource object previously created with
rd_kafka_ConfigResource_new()
rd_kafka_ConfigResource_destroy_array (Pointer <Pointer <rd_kafka_ConfigResource_t config , int config_cnt → void
@brief Helper function to destroy all ConfigResource objects in
the \p configs array (of \p config_cnt elements).
The array itself is not freed.
rd_kafka_ConfigResource_error (Pointer <rd_kafka_ConfigResource_t config → int
@returns the error for this resource from an AlterConfigs request
rd_kafka_ConfigResource_error_string (Pointer <rd_kafka_ConfigResource_t config → Pointer <Char
@returns the error string for this resource from an AlterConfigs
request, or NULL if no error.
rd_kafka_ConfigResource_name (Pointer <rd_kafka_ConfigResource_t config → Pointer <Char
@returns the name for \p config
rd_kafka_ConfigResource_new (int restype , Pointer <Char resname → Pointer <rd_kafka_ConfigResource_t
@brief Create new ConfigResource object.
rd_kafka_ConfigResource_set_config (Pointer <rd_kafka_ConfigResource_t config , Pointer <Char name , Pointer <Char value → int
@brief Set configuration name value pair.
rd_kafka_ConfigResource_type (Pointer <rd_kafka_ConfigResource_t config → int
@returns the ResourceType for \p config
rd_kafka_ConfigSource_name (int confsource → Pointer <Char
@returns a string representation of the \p confsource.
rd_kafka_consume (Pointer <rd_kafka_topic_t rkt , int partition , int timeout_ms → Pointer <rd_kafka_message_t
@brief Consume a single message from topic \p rkt and \p partition
rd_kafka_consume_batch (Pointer <rd_kafka_topic_t rkt , int partition , int timeout_ms , Pointer <Pointer <rd_kafka_message_t rkmessages , int rkmessages_size → int
@brief Consume up to \p rkmessages_size from topic \p rkt and \p partition
putting a pointer to each message in the application provided
array \p rkmessages (of size \p rkmessages_size entries).
rd_kafka_consume_batch_queue (Pointer <rd_kafka_queue_t rkqu , int timeout_ms , Pointer <Pointer <rd_kafka_message_t rkmessages , int rkmessages_size → int
@brief Consume batch of messages from queue
rd_kafka_consume_callback (Pointer <rd_kafka_topic_t rkt , int partition , int timeout_ms , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_message_t rkmessage , Pointer <Void commit_opaque consume_cb , Pointer <Void commit_opaque → int
@brief Consumes messages from topic \p rkt and \p partition, calling
the provided callback for each consumed messsage.
rd_kafka_consume_callback_queue (Pointer <rd_kafka_queue_t rkqu , int timeout_ms , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_message_t rkmessage , Pointer <Void commit_opaque consume_cb , Pointer <Void commit_opaque → int
@brief Consume multiple messages from queue with callback
rd_kafka_consume_queue (Pointer <rd_kafka_queue_t rkqu , int timeout_ms → Pointer <rd_kafka_message_t
@brief Consume from queue
rd_kafka_consume_start (Pointer <rd_kafka_topic_t rkt , int partition , int offset → int
@brief Start consuming messages for topic \p rkt and \p partition
at offset \p offset which may either be an absolute \c (0..N)
or one of the logical offsets:
rd_kafka_consume_start_queue (Pointer <rd_kafka_topic_t rkt , int partition , int offset , Pointer <rd_kafka_queue_t rkqu → int
@brief Same as rd_kafka_consume_start() but re-routes incoming messages to
the provided queue \p rkqu (which must have been previously allocated
with rd_kafka_queue_new().
rd_kafka_consume_stop (Pointer <rd_kafka_topic_t rkt , int partition → int
@brief Stop consuming messages for topic \p rkt and \p partition, purging
all messages currently in the local queue.
rd_kafka_consumer_close (Pointer <rd_kafka_t rk → int
@brief Close the consumer.
rd_kafka_consumer_close_queue (Pointer <rd_kafka_t rk , Pointer <rd_kafka_queue_t rkqu → Pointer <rd_kafka_error_t
@brief Asynchronously close the consumer.
rd_kafka_consumer_closed (Pointer <rd_kafka_t rk → int
@returns 1 if the consumer is closed, else 0.
rd_kafka_consumer_group_metadata (Pointer <rd_kafka_t rk → Pointer <rd_kafka_consumer_group_metadata_t
@returns the current consumer group metadata associated with this consumer,
or NULL if \p rk is not a consumer configured with a \c group.id.
This metadata object should be passed to the transactional
producer's rd_kafka_send_offsets_to_transaction() API.
rd_kafka_consumer_group_metadata_destroy (Pointer <rd_kafka_consumer_group_metadata_t arg0 → void
@brief Frees the consumer group metadata object as returned by
rd_kafka_consumer_group_metadata().
rd_kafka_consumer_group_metadata_generation_id (Pointer <rd_kafka_consumer_group_metadata_t group_metadata → int
@brief Get the generation id (classic protocol)
or member epoch (consumer protocol) of a group metadata.
rd_kafka_consumer_group_metadata_group_id (Pointer <rd_kafka_consumer_group_metadata_t group_metadata → Pointer <Char
@brief Get group id of a group metadata.
rd_kafka_consumer_group_metadata_group_instance_id (Pointer <rd_kafka_consumer_group_metadata_t group_metadata → Pointer <Char
@brief Get group instance id of a group metadata.
rd_kafka_consumer_group_metadata_member_id (Pointer <rd_kafka_consumer_group_metadata_t group_metadata → Pointer <Char
@brief Get member id of a group metadata.
rd_kafka_consumer_group_metadata_new (Pointer <Char group_id → Pointer <rd_kafka_consumer_group_metadata_t
@brief Create a new consumer group metadata object.
This is typically only used for writing tests.
rd_kafka_consumer_group_metadata_new_with_genid (Pointer <Char group_id , int generation_id , Pointer <Char member_id , Pointer <Char group_instance_id → Pointer <rd_kafka_consumer_group_metadata_t
@brief Create a new consumer group metadata object.
This is typically only used for writing tests.
rd_kafka_consumer_group_metadata_read (Pointer <Pointer <rd_kafka_consumer_group_metadata_t cgmdp , Pointer <Void buffer , int size → Pointer <rd_kafka_error_t
@brief Reads serialized consumer group metadata and returns a
consumer group metadata object.
This is mainly for client binding use and not for application use.
rd_kafka_consumer_group_metadata_write (Pointer <rd_kafka_consumer_group_metadata_t cgmd , Pointer <Pointer <Void bufferp , Pointer <Size sizep → Pointer <rd_kafka_error_t
@brief Serialize the consumer group metadata to a binary format.
This is mainly for client binding use and not for application use.
rd_kafka_consumer_group_state_code (Pointer <Char name → int
@brief Returns a code for a state name.
rd_kafka_consumer_group_state_name (int state → Pointer <Char
@brief Returns a name for a state code.
rd_kafka_consumer_group_type_code (Pointer <Char name → int
@brief Returns a code for a group type name.
rd_kafka_consumer_group_type_name (int type → Pointer <Char
@brief Returns a name for a group type code.
rd_kafka_consumer_poll (Pointer <rd_kafka_t rk , int timeout_ms → Pointer <rd_kafka_message_t
@brief Poll the consumer for messages or events.
rd_kafka_ConsumerGroupDescription_authorized_operations (Pointer <rd_kafka_ConsumerGroupDescription_t grpdesc , Pointer <Size cntp → Pointer <Int32
@brief Gets the authorized ACL operations for the \p grpdesc group.
rd_kafka_ConsumerGroupDescription_coordinator (Pointer <rd_kafka_ConsumerGroupDescription_t grpdesc → Pointer <rd_kafka_Node_t
@brief Gets the coordinator for the \p grpdesc group.
rd_kafka_ConsumerGroupDescription_error (Pointer <rd_kafka_ConsumerGroupDescription_t grpdesc → Pointer <rd_kafka_error_t
@brief Gets the error for the \p grpdesc group.
rd_kafka_ConsumerGroupDescription_group_id (Pointer <rd_kafka_ConsumerGroupDescription_t grpdesc → Pointer <Char
@brief Gets the group id for the \p grpdesc group.
rd_kafka_ConsumerGroupDescription_is_simple_consumer_group (Pointer <rd_kafka_ConsumerGroupDescription_t grpdesc → int
@brief Is the \p grpdesc group a simple consumer group.
rd_kafka_ConsumerGroupDescription_member (Pointer <rd_kafka_ConsumerGroupDescription_t grpdesc , int idx → Pointer <rd_kafka_MemberDescription_t
@brief Gets a member of \p grpdesc group.
rd_kafka_ConsumerGroupDescription_member_count (Pointer <rd_kafka_ConsumerGroupDescription_t grpdesc → int
@brief Gets the members count of \p grpdesc group.
rd_kafka_ConsumerGroupDescription_partition_assignor (Pointer <rd_kafka_ConsumerGroupDescription_t grpdesc → Pointer <Char
@brief Gets the partition assignor for the \p grpdesc group.
rd_kafka_ConsumerGroupDescription_state (Pointer <rd_kafka_ConsumerGroupDescription_t grpdesc → int
@brief Gets state for the \p grpdesc group.
rd_kafka_ConsumerGroupListing_group_id (Pointer <rd_kafka_ConsumerGroupListing_t grplist → Pointer <Char
@brief Gets the group id for the \p grplist group.
rd_kafka_ConsumerGroupListing_is_simple_consumer_group (Pointer <rd_kafka_ConsumerGroupListing_t grplist → int
@brief Is the \p grplist group a simple consumer group.
rd_kafka_ConsumerGroupListing_state (Pointer <rd_kafka_ConsumerGroupListing_t grplist → int
@brief Gets state for the \p grplist group.
rd_kafka_ConsumerGroupListing_type (Pointer <rd_kafka_ConsumerGroupListing_t grplist → int
@brief Gets type for the \p grplist group.
rd_kafka_controllerid (Pointer <rd_kafka_t rk , int timeout_ms → int
@brief Returns the current ControllerId as reported in broker metadata.
rd_kafka_CreateAcls (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_AclBinding_t new_acls , int new_acls_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Create acls as specified by the \p new_acls
array of size \p new_topic_cnt elements.
rd_kafka_CreateAcls_result_acls (Pointer <rd_kafka_CreateAcls_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_acl_result_t
@brief Get an array of acl results from a CreateAcls result.
rd_kafka_CreatePartitions (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_NewPartitions_t new_parts , int new_parts_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Create additional partitions for the given topics, as specified
by the \p new_parts array of size \p new_parts_cnt elements.
rd_kafka_CreatePartitions_result_topics (Pointer <rd_kafka_CreatePartitions_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_topic_result_t
@brief Get an array of topic results from a CreatePartitions result.
rd_kafka_CreateTopics (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_NewTopic_t new_topics , int new_topic_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Create topics in cluster as specified by the \p new_topics
array of size \p new_topic_cnt elements.
rd_kafka_CreateTopics_result_topics (Pointer <rd_kafka_CreateTopics_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_topic_result_t
@brief Get an array of topic results from a CreateTopics result.
rd_kafka_default_topic_conf_dup (Pointer <rd_kafka_t rk → Pointer <rd_kafka_topic_conf_t
@brief Creates a copy/duplicate of \p rk 's default topic configuration
object.
rd_kafka_DeleteAcls (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_AclBindingFilter_t del_acls , int del_acls_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Delete acls matching the filteres provided in \p del_acls
array of size \p del_acls_cnt.
rd_kafka_DeleteAcls_result_response_error (Pointer <rd_kafka_DeleteAcls_result_response_t result_response → Pointer <rd_kafka_error_t
@returns the error object for the given DeleteAcls result response,
or NULL on success.
rd_kafka_DeleteAcls_result_response_matching_acls (Pointer <rd_kafka_DeleteAcls_result_response_t result_response , Pointer <Size matching_acls_cntp → Pointer <Pointer <rd_kafka_AclBinding_t
@returns the matching acls array for the given DeleteAcls result response.
rd_kafka_DeleteAcls_result_responses (Pointer <rd_kafka_DeleteAcls_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_DeleteAcls_result_response_t
@brief Get an array of DeleteAcls result responses from a DeleteAcls result.
rd_kafka_DeleteConsumerGroupOffsets (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_DeleteConsumerGroupOffsets_t del_grpoffsets , int del_grpoffsets_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Delete committed offsets for a set of partitions in a consumer
group. This will succeed at the partition level only if the group
is not actively subscribed to the corresponding topic.
rd_kafka_DeleteConsumerGroupOffsets_destroy (Pointer <rd_kafka_DeleteConsumerGroupOffsets_t del_grpoffsets → void
@brief Destroy and free a DeleteConsumerGroupOffsets object previously
created with rd_kafka_DeleteConsumerGroupOffsets_new()
rd_kafka_DeleteConsumerGroupOffsets_destroy_array (Pointer <Pointer <rd_kafka_DeleteConsumerGroupOffsets_t del_grpoffsets , int del_grpoffset_cnt → void
@brief Helper function to destroy all DeleteConsumerGroupOffsets objects in
the \p del_grpoffsets array (of \p del_grpoffsets_cnt elements).
The array itself is not freed.
rd_kafka_DeleteConsumerGroupOffsets_new (Pointer <Char group , Pointer <rd_kafka_topic_partition_list_t partitions → Pointer <rd_kafka_DeleteConsumerGroupOffsets_t
@brief Create a new DeleteConsumerGroupOffsets object.
This object is later passed to rd_kafka_DeleteConsumerGroupOffsets().
rd_kafka_DeleteConsumerGroupOffsets_result_groups (Pointer <rd_kafka_DeleteConsumerGroupOffsets_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_group_result_t
@brief Get an array of results from a DeleteConsumerGroupOffsets result.
rd_kafka_DeleteGroup_destroy (Pointer <rd_kafka_DeleteGroup_t del_group → void
@brief Destroy and free a DeleteGroup object previously created with
rd_kafka_DeleteGroup_new()
rd_kafka_DeleteGroup_destroy_array (Pointer <Pointer <rd_kafka_DeleteGroup_t del_groups , int del_group_cnt → void
@brief Helper function to destroy all DeleteGroup objects in
the \p del_groups array (of \p del_group_cnt elements).
The array itself is not freed.
rd_kafka_DeleteGroup_new (Pointer <Char group → Pointer <rd_kafka_DeleteGroup_t
@brief Create a new DeleteGroup object. This object is later passed to
rd_kafka_DeleteGroups().
rd_kafka_DeleteGroups (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_DeleteGroup_t del_groups , int del_group_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Delete groups from cluster as specified by the \p del_groups
array of size \p del_group_cnt elements.
rd_kafka_DeleteGroups_result_groups (Pointer <rd_kafka_DeleteGroups_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_group_result_t
@brief Get an array of group results from a DeleteGroups result.
rd_kafka_DeleteRecords (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_DeleteRecords_t del_records , int del_record_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Delete records (messages) in topic partitions older than the
offsets provided.
rd_kafka_DeleteRecords_destroy (Pointer <rd_kafka_DeleteRecords_t del_records → void
@brief Destroy and free a DeleteRecords object previously created with
rd_kafka_DeleteRecords_new()
rd_kafka_DeleteRecords_destroy_array (Pointer <Pointer <rd_kafka_DeleteRecords_t del_records , int del_record_cnt → void
@brief Helper function to destroy all DeleteRecords objects in
the \p del_groups array (of \p del_group_cnt elements).
The array itself is not freed.
rd_kafka_DeleteRecords_new (Pointer <rd_kafka_topic_partition_list_t before_offsets → Pointer <rd_kafka_DeleteRecords_t
@brief Create a new DeleteRecords object. This object is later passed to
rd_kafka_DeleteRecords().
rd_kafka_DeleteRecords_result_offsets (Pointer <rd_kafka_DeleteRecords_result_t result → Pointer <rd_kafka_topic_partition_list_t
@brief Get a list of topic and partition results from a DeleteRecords result.
The returned objects will contain \c topic, \c partition, \c offset
and \c err. \c offset will be set to the post-deletion low-watermark
(smallest available offset of all live replicas). \c err will be set
per-partition if deletion failed.
rd_kafka_DeleteTopic_destroy (Pointer <rd_kafka_DeleteTopic_t del_topic → void
@brief Destroy and free a DeleteTopic object previously created with
rd_kafka_DeleteTopic_new()
rd_kafka_DeleteTopic_destroy_array (Pointer <Pointer <rd_kafka_DeleteTopic_t del_topics , int del_topic_cnt → void
@brief Helper function to destroy all DeleteTopic objects in
the \p del_topics array (of \p del_topic_cnt elements).
The array itself is not freed.
rd_kafka_DeleteTopic_new (Pointer <Char topic → Pointer <rd_kafka_DeleteTopic_t
@brief Create a new DeleteTopic object. This object is later passed to
rd_kafka_DeleteTopics().
rd_kafka_DeleteTopics (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_DeleteTopic_t del_topics , int del_topic_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Delete topics from cluster as specified by the \p topics
array of size \p topic_cnt elements.
rd_kafka_DeleteTopics_result_topics (Pointer <rd_kafka_DeleteTopics_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_topic_result_t
@brief Get an array of topic results from a DeleteTopics result.
rd_kafka_DescribeAcls (Pointer <rd_kafka_t rk , Pointer <rd_kafka_AclBindingFilter_t acl_filter , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Describe acls matching the filter provided in \p acl_filter
rd_kafka_DescribeAcls_result_acls (Pointer <rd_kafka_DescribeAcls_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_AclBinding_t
@brief Get an array of resource results from a DescribeAcls result.
rd_kafka_DescribeCluster (Pointer <rd_kafka_t rk , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Describes the cluster.
rd_kafka_DescribeCluster_result_authorized_operations (Pointer <rd_kafka_DescribeCluster_result_t result , Pointer <Size cntp → Pointer <Int32
@brief Gets the authorized ACL operations for the \p result cluster.
rd_kafka_DescribeCluster_result_cluster_id (Pointer <rd_kafka_DescribeCluster_result_t result → Pointer <Char
@brief Gets the cluster id for the \p result cluster.
rd_kafka_DescribeCluster_result_controller (Pointer <rd_kafka_DescribeCluster_result_t result → Pointer <rd_kafka_Node_t
@brief Gets the current controller for the \p result cluster.
rd_kafka_DescribeCluster_result_nodes (Pointer <rd_kafka_DescribeCluster_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_Node_t
@brief Gets the broker nodes for the \p result cluster.
rd_kafka_DescribeConfigs (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_ConfigResource_t configs , int config_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Get configuration for the specified resources in \p configs.
rd_kafka_DescribeConfigs_result_resources (Pointer <rd_kafka_DescribeConfigs_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_ConfigResource_t
@brief Get an array of resource results from a DescribeConfigs result.
rd_kafka_DescribeConsumerGroups (Pointer <rd_kafka_t rk , Pointer <Pointer <Char groups , int groups_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Describe groups from cluster as specified by the \p groups
array of size \p groups_cnt elements.
rd_kafka_DescribeConsumerGroups_result_groups (Pointer <rd_kafka_DescribeConsumerGroups_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_ConsumerGroupDescription_t
@brief Get an array of group results from a DescribeConsumerGroups result.
rd_kafka_DescribeTopics (Pointer <rd_kafka_t rk , Pointer <rd_kafka_TopicCollection_t topics , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Describe topics as specified by the \p topics
array of size \p topics_cnt elements.
rd_kafka_DescribeTopics_result_topics (Pointer <rd_kafka_DescribeTopics_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_TopicDescription_t
@brief Get an array of topic results from a DescribeTopics result.
rd_kafka_DescribeUserScramCredentials (Pointer <rd_kafka_t rk , Pointer <Pointer <Char users , int user_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Describe SASL/SCRAM credentials.
This operation is supported by brokers with version 2.7.0 or higher.
rd_kafka_DescribeUserScramCredentials_result_descriptions (Pointer <rd_kafka_DescribeUserScramCredentials_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_UserScramCredentialsDescription_t
@brief Get an array of descriptions from a DescribeUserScramCredentials
result.
rd_kafka_destroy (Pointer <rd_kafka_t rk → void
@brief Destroy Kafka handle.
rd_kafka_destroy_flags (Pointer <rd_kafka_t rk , int flags → void
@brief Destroy Kafka handle according to specified destroy flags
rd_kafka_dump (Pointer <FILE fp , Pointer <rd_kafka_t rk → void
@brief Dumps rdkafka's internal state for handle \p rk to stream \p fp
rd_kafka_ElectLeaders (Pointer <rd_kafka_t rk , Pointer <rd_kafka_ElectLeaders_t elect_leaders , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Elect Leaders for the provided Topic Partitions
according to the specified election type.
rd_kafka_ElectLeaders_destroy (Pointer <rd_kafka_ElectLeaders_t elect_leaders → void
@brief Destroy and free a rd_kafka_ElectLeaders_t object previously created
with rd_kafka_ElectLeaders_new()
rd_kafka_ElectLeaders_new (int election_type , Pointer <rd_kafka_topic_partition_list_t partitions → Pointer <rd_kafka_ElectLeaders_t
@brief Create a new rd_kafka_ElectLeaders_t object. This object is later
passed to rd_kafka_ElectLeaders().
rd_kafka_ElectLeaders_result_partitions (Pointer <rd_kafka_ElectLeaders_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_topic_partition_result_t
@brief Get the array of topic partition result objects from the
elect leaders result event and populates the size of the
array in \p cntp.
rd_kafka_err2name (int err → Pointer <Char
@brief Returns the error code name (enum name).
rd_kafka_err2str (int err → Pointer <Char
@brief Returns a human readable representation of a kafka error.
rd_kafka_errno ()
→ int
@brief Returns the thread-local system errno
rd_kafka_errno2err (int errnox → int
@brief Converts the system errno value \p errnox to a rd_kafka_resp_err_t
error code upon failure from the following functions:
rd_kafka_error_code (Pointer <rd_kafka_error_t error → int
@returns the error code for \p error or RD_KAFKA_RESP_ERR_NO_ERROR if
\p error is NULL.
rd_kafka_error_destroy (Pointer <rd_kafka_error_t error → void
@brief Free and destroy an error object.
rd_kafka_error_is_fatal (Pointer <rd_kafka_error_t error → int
@returns 1 if the error is a fatal error, indicating that the client
instance is no longer usable, else 0 (also if \p error is NULL).
rd_kafka_error_is_retriable (Pointer <rd_kafka_error_t error → int
@returns 1 if the operation may be retried,
else 0 (also if \p error is NULL).
rd_kafka_error_name (Pointer <rd_kafka_error_t error → Pointer <Char
@returns the error code name for \p error, e.g, "ERR_UNKNOWN_MEMBER_ID",
or an empty string if \p error is NULL.
rd_kafka_error_new (int code , Pointer <Char fmt → Pointer <rd_kafka_error_t
@brief Create a new error object with error \p code and optional
human readable error string in \p fmt.
rd_kafka_error_string (Pointer <rd_kafka_error_t error → Pointer <Char
@returns a human readable error string for \p error,
or an empty string if \p error is NULL.
rd_kafka_error_txn_requires_abort (Pointer <rd_kafka_error_t error → int
@returns 1 if the error is an abortable transaction error in which case
the application must call rd_kafka_abort_transaction() and
start a new transaction with rd_kafka_begin_transaction() if it
wishes to proceed with transactions.
Else returns 0 (also if \p error is NULL).
rd_kafka_event_AlterConfigs_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_AlterConfigs_result_t
@brief Get AlterConfigs result.
rd_kafka_event_AlterConsumerGroupOffsets_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_AlterConsumerGroupOffsets_result_t
@brief Get AlterConsumerGroupOffsets result.
rd_kafka_event_AlterUserScramCredentials_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_AlterUserScramCredentials_result_t
@brief Get AlterUserScramCredentials result.
rd_kafka_event_config_string (Pointer <rd_kafka_event_t rkev → Pointer <Char
@returns the associated configuration string for the event, or NULL
if the configuration property is not set or if
not applicable for the given event type.
rd_kafka_event_CreateAcls_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_CreateAcls_result_t
@returns the result of a CreateAcls request, or NULL if event is of
different type.
rd_kafka_event_CreatePartitions_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_CreatePartitions_result_t
@brief Get CreatePartitions result.
rd_kafka_event_CreateTopics_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_CreateTopics_result_t
@brief Get CreateTopics result.
rd_kafka_event_debug_contexts (Pointer <rd_kafka_event_t rkev , Pointer <Char dst , int dstsize → int
@brief Extract log debug context from event.
rd_kafka_event_DeleteAcls_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DeleteAcls_result_t
@returns the result of a DeleteAcls request, or NULL if event is of
different type.
rd_kafka_event_DeleteConsumerGroupOffsets_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DeleteConsumerGroupOffsets_result_t
@brief Get DeleteConsumerGroupOffsets result.
rd_kafka_event_DeleteGroups_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DeleteGroups_result_t
@brief Get DeleteGroups result.
rd_kafka_event_DeleteRecords_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DeleteRecords_result_t
@returns the result of a DeleteRecords request, or NULL if event is of
different type.
rd_kafka_event_DeleteTopics_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DeleteTopics_result_t
@brief Get DeleteTopics result.
rd_kafka_event_DescribeAcls_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DescribeAcls_result_t
@returns the result of a DescribeAcls request, or NULL if event is of
different type.
rd_kafka_event_DescribeCluster_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DescribeCluster_result_t
@brief Get DescribeCluster result.
rd_kafka_event_DescribeConfigs_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DescribeConfigs_result_t
@brief Get DescribeConfigs result.
rd_kafka_event_DescribeConsumerGroups_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DescribeConsumerGroups_result_t
@brief Get DescribeConsumerGroups result.
rd_kafka_event_DescribeTopics_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DescribeTopics_result_t
@brief Get DescribeTopics result.
rd_kafka_event_DescribeUserScramCredentials_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_DescribeUserScramCredentials_result_t
@brief Get DescribeUserScramCredentials result.
rd_kafka_event_destroy (Pointer <rd_kafka_event_t rkev → void
@brief Destroy an event.
rd_kafka_event_ElectLeaders_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_ElectLeaders_result_t
@brief Get ElectLeaders result.
rd_kafka_event_error (Pointer <rd_kafka_event_t rkev → int
@returns the error code for the event.
rd_kafka_event_error_is_fatal (Pointer <rd_kafka_event_t rkev → int
@returns 1 if the error is a fatal error, else 0.
rd_kafka_event_error_string (Pointer <rd_kafka_event_t rkev → Pointer <Char
@returns the error string (if any).
An application should check that rd_kafka_event_error() returns
non-zero before calling this function.
rd_kafka_event_IncrementalAlterConfigs_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_IncrementalAlterConfigs_result_t
@brief Get IncrementalAlterConfigs result.
rd_kafka_event_ListConsumerGroupOffsets_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_ListConsumerGroupOffsets_result_t
@brief Get ListConsumerGroupOffsets result.
rd_kafka_event_ListConsumerGroups_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_ListConsumerGroups_result_t
@brief Get ListConsumerGroups result.
rd_kafka_event_ListOffsets_result (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_ListOffsets_result_t
@brief Get ListOffsets result.
rd_kafka_event_log (Pointer <rd_kafka_event_t rkev , Pointer <Pointer <Char fac , Pointer <Pointer <Char str , Pointer <Int level → int
@brief Extract log message from the event.
rd_kafka_event_message_array (Pointer <rd_kafka_event_t rkev , Pointer <Pointer <rd_kafka_message_t rkmessages , int size → int
@brief Extacts \p size message(s) from the event into the
pre-allocated array \p rkmessages.
rd_kafka_event_message_count (Pointer <rd_kafka_event_t rkev → int
@returns the number of remaining messages in the event.
rd_kafka_event_message_next (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_message_t
@returns the next message from an event.
rd_kafka_event_name (Pointer <rd_kafka_event_t rkev → Pointer <Char
@returns the event type's name for the given event.
rd_kafka_event_opaque (Pointer <rd_kafka_event_t rkev → Pointer <Void
@returns the event opaque (if any) as passed to rd_kafka_commit() (et.al) or
rd_kafka_AdminOptions_set_opaque(), depending on event type.
rd_kafka_event_stats (Pointer <rd_kafka_event_t rkev → Pointer <Char
@brief Extract stats from the event.
rd_kafka_event_topic_partition (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_topic_partition_t
@returns a newly allocated topic_partition container, if applicable for the
event type, else NULL.
rd_kafka_event_topic_partition_list (Pointer <rd_kafka_event_t rkev → Pointer <rd_kafka_topic_partition_list_t
@returns the topic partition list from the event.
rd_kafka_event_type (Pointer <rd_kafka_event_t rkev → int
@returns the event type for the given event.
rd_kafka_fatal_error (Pointer <rd_kafka_t rk , Pointer <Char errstr , int errstr_size → int
@brief Returns the first fatal error set on this client instance,
or RD_KAFKA_RESP_ERR_NO_ERROR if no fatal error has occurred.
rd_kafka_flush (Pointer <rd_kafka_t rk , int timeout_ms → int
@brief Wait until all outstanding produce requests, et.al, are completed.
This should typically be done prior to destroying a producer instance
to make sure all queued and in-flight produce requests are completed
before terminating.
rd_kafka_get_debug_contexts ()
→ Pointer <Char
@brief Retrieve supported debug contexts for use with the \c "debug"
configuration property. (runtime)
rd_kafka_get_err_descs (Pointer <Pointer <rd_kafka_err_desc errdescs , Pointer <Size cntp → void
@brief Returns the full list of error codes.
rd_kafka_get_watermark_offsets (Pointer <rd_kafka_t rk , Pointer <Char topic , int partition , Pointer <Int64 low , Pointer <Int64 high → int
@brief Get last known low (oldest/beginning) and high (newest/end) offsets
for partition.
rd_kafka_group_list_destroy (Pointer <rd_kafka_group_list grplist → void
@brief Release list memory
rd_kafka_group_result_error (Pointer <rd_kafka_group_result_t groupres → Pointer <rd_kafka_error_t
@returns the error for the given group result, or NULL on success.
@remark lifetime of the returned error is the same as the \p groupres.
rd_kafka_group_result_name (Pointer <rd_kafka_group_result_t groupres → Pointer <Char
@returns the name of the group for the given group result.
@remark lifetime of the returned string is the same as the \p groupres.
rd_kafka_group_result_partitions (Pointer <rd_kafka_group_result_t groupres → Pointer <rd_kafka_topic_partition_list_t
@returns the partitions/offsets for the given group result, if applicable
to the request type, else NULL.
@remark lifetime of the returned list is the same as the \p groupres.
@brief Add header with name \p name and value \p val (copied) of size
\p size (not including null-terminator).
@brief Returns the number of header key/value pairs
@brief Iterator for headers matching \p name.
@brief Iterator for all headers.
@brief Find last header in list \p hdrs matching \p name.
@brief Remove all headers for the given key (if any).
@brief Make a copy of headers list \p src.
@brief Destroy the headers list. The object and any returned value pointers
are not usable after this call.
@brief Create a new headers list.
rd_kafka_incremental_assign (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t partitions → Pointer <rd_kafka_error_t
@brief Incrementally add \p partitions to the current assignment.
rd_kafka_incremental_unassign (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t partitions → Pointer <rd_kafka_error_t
@brief Incrementally remove \p partitions from the current assignment.
rd_kafka_IncrementalAlterConfigs (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_ConfigResource_t configs , int config_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief Incrementally update the configuration for the specified resources.
Updates are not transactional so they may succeed for some resources
while fail for others. The configs for a particular resource are
updated atomically, executing the corresponding incremental operations
on the provided configurations.
rd_kafka_IncrementalAlterConfigs_result_resources (Pointer <rd_kafka_IncrementalAlterConfigs_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_ConfigResource_t
@brief Get an array of resource results from a IncrementalAlterConfigs
result.
rd_kafka_init_transactions (Pointer <rd_kafka_t rk , int timeout_ms → Pointer <rd_kafka_error_t
@brief Initialize transactions for the producer instance.
rd_kafka_interceptor_add_on_acknowledgement (Pointer <rd_kafka_t rk , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_acknowledgement_t on_acknowledgement , Pointer <Void ic_opaque → int
@brief Append an on_acknowledgement() interceptor.
rd_kafka_interceptor_add_on_broker_state_change (Pointer <rd_kafka_t rk , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_broker_state_change_t on_broker_state_change , Pointer <Void ic_opaque → int
@brief Append an on_broker_state_change() interceptor.
rd_kafka_interceptor_add_on_commit (Pointer <rd_kafka_t rk , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_commit_t on_commit , Pointer <Void ic_opaque → int
@brief Append an on_commit() interceptor.
rd_kafka_interceptor_add_on_consume (Pointer <rd_kafka_t rk , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_consume_t on_consume , Pointer <Void ic_opaque → int
@brief Append an on_consume() interceptor.
rd_kafka_interceptor_add_on_destroy (Pointer <rd_kafka_t rk , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_destroy_t on_destroy , Pointer <Void ic_opaque → int
@brief Append an on_destroy() interceptor.
rd_kafka_interceptor_add_on_request_sent (Pointer <rd_kafka_t rk , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_request_sent_t on_request_sent , Pointer <Void ic_opaque → int
@brief Append an on_request_sent() interceptor.
rd_kafka_interceptor_add_on_response_received (Pointer <rd_kafka_t rk , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_response_received_t on_response_received , Pointer <Void ic_opaque → int
@brief Append an on_response_received() interceptor.
rd_kafka_interceptor_add_on_send (Pointer <rd_kafka_t rk , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_send_t on_send , Pointer <Void ic_opaque → int
@brief Append an on_send() interceptor.
rd_kafka_interceptor_add_on_thread_exit (Pointer <rd_kafka_t rk , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_thread_exit_t on_thread_exit , Pointer <Void ic_opaque → int
@brief Append an on_thread_exit() interceptor.
rd_kafka_interceptor_add_on_thread_start (Pointer <rd_kafka_t rk , Pointer <Char ic_name , Pointer <rd_kafka_interceptor_f_on_thread_start_t on_thread_start , Pointer <Void ic_opaque → int
@brief Append an on_thread_start() interceptor.
rd_kafka_last_error ()
→ int
@brief Returns the last error code generated by a legacy API call
in the current thread.
rd_kafka_list_groups (Pointer <rd_kafka_t rk , Pointer <Char group , Pointer <Pointer <rd_kafka_group_list grplistp , int timeout_ms → int
@brief List and describe client groups in cluster.
rd_kafka_ListConsumerGroupOffsets (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_ListConsumerGroupOffsets_t list_grpoffsets , int list_grpoffsets_cnt , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief List committed offsets for a set of partitions in a consumer
group.
rd_kafka_ListConsumerGroupOffsets_destroy (Pointer <rd_kafka_ListConsumerGroupOffsets_t list_grpoffsets → void
@brief Destroy and free a ListConsumerGroupOffsets object previously
created with rd_kafka_ListConsumerGroupOffsets_new()
rd_kafka_ListConsumerGroupOffsets_destroy_array (Pointer <Pointer <rd_kafka_ListConsumerGroupOffsets_t list_grpoffsets , int list_grpoffset_cnt → void
@brief Helper function to destroy all ListConsumerGroupOffsets objects in
the \p list_grpoffsets array (of \p list_grpoffsets_cnt elements).
The array itself is not freed.
rd_kafka_ListConsumerGroupOffsets_new (Pointer <Char group_id , Pointer <rd_kafka_topic_partition_list_t partitions → Pointer <rd_kafka_ListConsumerGroupOffsets_t
@brief Create a new ListConsumerGroupOffsets object.
This object is later passed to rd_kafka_ListConsumerGroupOffsets().
rd_kafka_ListConsumerGroupOffsets_result_groups (Pointer <rd_kafka_ListConsumerGroupOffsets_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_group_result_t
@brief Get an array of results from a ListConsumerGroupOffsets result.
rd_kafka_ListConsumerGroups (Pointer <rd_kafka_t rk , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief List the consumer groups available in the cluster.
rd_kafka_ListConsumerGroups_result_errors (Pointer <rd_kafka_ListConsumerGroups_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_error_t
@brief Get an array of errors from a ListConsumerGroups call result.
rd_kafka_ListConsumerGroups_result_valid (Pointer <rd_kafka_ListConsumerGroups_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_ConsumerGroupListing_t
@brief Get an array of valid list groups from a ListConsumerGroups result.
rd_kafka_ListOffsets (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t topic_partitions , Pointer <rd_kafka_AdminOptions_t options , Pointer <rd_kafka_queue_t rkqu → void
@brief List offsets for the specified \p topic_partitions.
This operation enables to find the beginning offset,
end offset as well as the offset matching a timestamp in partitions
or the offset with max timestamp.
rd_kafka_ListOffsets_result_infos (Pointer <rd_kafka_ListOffsets_result_t result , Pointer <Size cntp → Pointer <Pointer <rd_kafka_ListOffsetsResultInfo_t
@brief Returns the array of ListOffsetsResultInfo in \p result
and populates the size of the array in \p cntp.
rd_kafka_ListOffsetsResultInfo_timestamp (Pointer <rd_kafka_ListOffsetsResultInfo_t result_info → int
@brief Returns the timestamp corresponding to the offset in \p result_info.
rd_kafka_ListOffsetsResultInfo_topic_partition (Pointer <rd_kafka_ListOffsetsResultInfo_t result_info → Pointer <rd_kafka_topic_partition_t
@brief Returns the topic partition of the passed \p result_info.
rd_kafka_log_print (Pointer <rd_kafka_t rk , int level , Pointer <Char fac , Pointer <Char buf → void
@brief Builtin (default) log sink: print to stderr
rd_kafka_log_syslog (Pointer <rd_kafka_t rk , int level , Pointer <Char fac , Pointer <Char buf → void
@brief Builtin log sink: print to syslog.
@remark This logger is only available if librdkafka was built
with syslog support.
rd_kafka_mem_calloc (Pointer <rd_kafka_t rk , int num , int size → Pointer <Void
@brief Allocate and zero memory using the same allocator librdkafka uses.
rd_kafka_mem_free (Pointer <rd_kafka_t rk , Pointer <Void ptr → void
@brief Free pointer returned by librdkafka
rd_kafka_mem_malloc (Pointer <rd_kafka_t rk , int size → Pointer <Void
@brief Allocate memory using the same allocator librdkafka uses.
rd_kafka_MemberAssignment_partitions (Pointer <rd_kafka_MemberAssignment_t assignment → Pointer <rd_kafka_topic_partition_list_t
@brief Gets assigned partitions of a member \p assignment.
rd_kafka_MemberDescription_assignment (Pointer <rd_kafka_MemberDescription_t member → Pointer <rd_kafka_MemberAssignment_t
@brief Gets assignment of \p member.
rd_kafka_MemberDescription_client_id (Pointer <rd_kafka_MemberDescription_t member → Pointer <Char
@brief Gets client id of \p member.
rd_kafka_MemberDescription_consumer_id (Pointer <rd_kafka_MemberDescription_t member → Pointer <Char
@brief Gets consumer id of \p member.
rd_kafka_MemberDescription_group_instance_id (Pointer <rd_kafka_MemberDescription_t member → Pointer <Char
@brief Gets group instance id of \p member.
rd_kafka_MemberDescription_host (Pointer <rd_kafka_MemberDescription_t member → Pointer <Char
@brief Gets host of \p member.
rd_kafka_memberid (Pointer <rd_kafka_t rk → Pointer <Char
@brief Returns this client's broker-assigned group member id.
rd_kafka_message_broker_id (Pointer <rd_kafka_message_t rkmessage → int
@brief Returns the broker id of the broker the message was produced to
or fetched from.
rd_kafka_message_destroy (Pointer <rd_kafka_message_t rkmessage → void
@brief Frees resources for \p rkmessage and hands ownership back to rdkafka.
@brief Get the message header list and detach the list from the message
making the application the owner of the headers.
The application must eventually destroy the headers using
rd_kafka_headers_destroy().
The message's headers will be set to NULL.
rd_kafka_message_errstr (Pointer <rd_kafka_message_t rkmessage → Pointer <Char
@brief Returns the error string for an errored rd_kafka_message_t or NULL if
there was no error.
@brief Get the message header list.
rd_kafka_message_latency (Pointer <rd_kafka_message_t rkmessage → int
@brief Returns the latency for a produced message measured from
the produce() call.
rd_kafka_message_leader_epoch (Pointer <rd_kafka_message_t rkmessage → int
@returns the message's partition leader epoch at the time the message was
fetched and if known, else -1.
rd_kafka_message_produce_errstr (Pointer <rd_kafka_message_t rkmessage → Pointer <Char
@brief Returns the error string for an errored produced rd_kafka_message_t or
NULL if there was no error.
@brief Replace the message's current headers with a new list.
rd_kafka_message_status (Pointer <rd_kafka_message_t rkmessage → int
@brief Returns the message's persistence status in the topic log.
rd_kafka_message_timestamp (Pointer <rd_kafka_message_t rkmessage , Pointer <Int32 tstype → int
@brief Returns the message timestamp for a consumed message.
rd_kafka_metadata1 (Pointer <rd_kafka_t rk , int all_topics , Pointer <rd_kafka_topic_t only_rkt , Pointer <Pointer <rd_kafka_metadata metadatap , int timeout_ms → int
@brief Request Metadata from broker.
rd_kafka_metadata_destroy (Pointer <rd_kafka_metadata metadata → void
@brief Release metadata memory.
rd_kafka_msg_partitioner_consistent (Pointer <rd_kafka_topic_t rkt , Pointer <Void key , int keylen , int partition_cnt , Pointer <Void rkt_opaque , Pointer <Void msg_opaque → int
@brief Consistent partitioner.
rd_kafka_msg_partitioner_consistent_random (Pointer <rd_kafka_topic_t rkt , Pointer <Void key , int keylen , int partition_cnt , Pointer <Void rkt_opaque , Pointer <Void msg_opaque → int
@brief Consistent-Random partitioner.
rd_kafka_msg_partitioner_fnv1a (Pointer <rd_kafka_topic_t rkt , Pointer <Void key , int keylen , int partition_cnt , Pointer <Void rkt_opaque , Pointer <Void msg_opaque → int
@brief FNV-1a partitioner.
rd_kafka_msg_partitioner_fnv1a_random (Pointer <rd_kafka_topic_t rkt , Pointer <Void key , int keylen , int partition_cnt , Pointer <Void rkt_opaque , Pointer <Void msg_opaque → int
@brief Consistent-Random FNV-1a partitioner.
rd_kafka_msg_partitioner_murmur2 (Pointer <rd_kafka_topic_t rkt , Pointer <Void key , int keylen , int partition_cnt , Pointer <Void rkt_opaque , Pointer <Void msg_opaque → int
@brief Murmur2 partitioner (Java compatible).
rd_kafka_msg_partitioner_murmur2_random (Pointer <rd_kafka_topic_t rkt , Pointer <Void key , int keylen , int partition_cnt , Pointer <Void rkt_opaque , Pointer <Void msg_opaque → int
@brief Consistent-Random Murmur2 partitioner (Java compatible).
rd_kafka_msg_partitioner_random (Pointer <rd_kafka_topic_t rkt , Pointer <Void key , int keylen , int partition_cnt , Pointer <Void rkt_opaque , Pointer <Void msg_opaque → int
@brief Random partitioner.
rd_kafka_name (Pointer <rd_kafka_t rk → Pointer <Char
@brief Returns Kafka handle name.
rd_kafka_new (int type , Pointer <rd_kafka_conf_t conf , Pointer <Char errstr , int errstr_size → Pointer <rd_kafka_t
@brief Creates a new Kafka handle and starts its operation according to the
specified \p type (\p RD_KAFKA_CONSUMER or \p RD_KAFKA_PRODUCER).
rd_kafka_NewPartitions_destroy (Pointer <rd_kafka_NewPartitions_t new_parts → void
@brief Destroy and free a NewPartitions object previously created with
rd_kafka_NewPartitions_new()
rd_kafka_NewPartitions_destroy_array (Pointer <Pointer <rd_kafka_NewPartitions_t new_parts , int new_parts_cnt → void
@brief Helper function to destroy all NewPartitions objects in the
\p new_parts array (of \p new_parts_cnt elements).
The array itself is not freed.
rd_kafka_NewPartitions_new (Pointer <Char topic , int new_total_cnt , Pointer <Char errstr , int errstr_size → Pointer <rd_kafka_NewPartitions_t
@brief Create a new NewPartitions. This object is later passed to
rd_kafka_CreatePartitions() to increase the number of partitions
to \p new_total_cnt for an existing topic.
rd_kafka_NewPartitions_set_replica_assignment (Pointer <rd_kafka_NewPartitions_t new_parts , int new_partition_idx , Pointer <Int32 broker_ids , int broker_id_cnt , Pointer <Char errstr , int errstr_size → int
@brief Set the replica (broker id) assignment for \p new_partition_idx to the
replica set in \p broker_ids (of \p broker_id_cnt elements).
rd_kafka_NewTopic_destroy (Pointer <rd_kafka_NewTopic_t new_topic → void
@brief Destroy and free a NewTopic object previously created with
rd_kafka_NewTopic_new()
rd_kafka_NewTopic_destroy_array (Pointer <Pointer <rd_kafka_NewTopic_t new_topics , int new_topic_cnt → void
@brief Helper function to destroy all NewTopic objects in the \p new_topics
array (of \p new_topic_cnt elements).
The array itself is not freed.
rd_kafka_NewTopic_new (Pointer <Char topic , int num_partitions , int replication_factor , Pointer <Char errstr , int errstr_size → Pointer <rd_kafka_NewTopic_t
@brief Create a new NewTopic object. This object is later passed to
rd_kafka_CreateTopics().
rd_kafka_NewTopic_set_config (Pointer <rd_kafka_NewTopic_t new_topic , Pointer <Char name , Pointer <Char value → int
@brief Set (broker-side) topic configuration name/value pair.
rd_kafka_NewTopic_set_replica_assignment (Pointer <rd_kafka_NewTopic_t new_topic , int partition , Pointer <Int32 broker_ids , int broker_id_cnt , Pointer <Char errstr , int errstr_size → int
@brief Set the replica (broker) assignment for \p partition to the
replica set in \p broker_ids (of \p broker_id_cnt elements).
rd_kafka_Node_host (Pointer <rd_kafka_Node_t node → Pointer <Char
@brief Get the host of \p node.
rd_kafka_Node_id (Pointer <rd_kafka_Node_t node → int
@brief Get the id of \p node.
rd_kafka_Node_port (Pointer <rd_kafka_Node_t node → int
@brief Get the port of \p node.
rd_kafka_Node_rack (Pointer <rd_kafka_Node_t node → Pointer <Char
@brief Get the rack of \p node.
rd_kafka_oauthbearer_set_token (Pointer <rd_kafka_t rk , Pointer <Char token_value , int md_lifetime_ms , Pointer <Char md_principal_name , Pointer <Pointer <Char extensions , int extension_size , Pointer <Char errstr , int errstr_size → int
@brief Set SASL/OAUTHBEARER token and metadata
rd_kafka_oauthbearer_set_token_failure (Pointer <rd_kafka_t rk , Pointer <Char errstr → int
@brief SASL/OAUTHBEARER token refresh failure indicator.
rd_kafka_offset_store (Pointer <rd_kafka_topic_t rkt , int partition , int offset → int
@brief Store offset \p offset + 1 for topic \p rkt partition \p partition.
rd_kafka_offset_store_message (Pointer <rd_kafka_message_t rkmessage → Pointer <rd_kafka_error_t
@brief Store offset +1 for the consumed message.
rd_kafka_offsets_for_times (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t offsets , int timeout_ms → int
@brief Look up the offsets for the given partitions by timestamp.
rd_kafka_offsets_store (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t offsets → int
@brief Store offsets for next auto-commit for one or more partitions.
rd_kafka_opaque (Pointer <rd_kafka_t rk → Pointer <Void
@brief Retrieves the opaque pointer previously set
with rd_kafka_conf_set_opaque()
rd_kafka_outq_len (Pointer <rd_kafka_t rk → int
@brief Returns the current out queue length.
rd_kafka_pause_partitions (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t partitions → int
@brief Pause producing or consumption for the provided list of partitions.
rd_kafka_poll (Pointer <rd_kafka_t rk , int timeout_ms → int
@brief Polls the provided kafka handle for events.
rd_kafka_poll_set_consumer (Pointer <rd_kafka_t rk → int
@brief Redirect the main (rd_kafka_poll()) queue to the KafkaConsumer's
queue (rd_kafka_consumer_poll()).
rd_kafka_position (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t partitions → int
@brief Retrieve current positions (offsets) for topics+partitions.
rd_kafka_produce (Pointer <rd_kafka_topic_t rkt , int partition , int msgflags , Pointer <Void payload , int len , Pointer <Void key , int keylen , Pointer <Void msg_opaque → int
@brief Produce and send a single message to broker.
rd_kafka_produce_batch (Pointer <rd_kafka_topic_t rkt , int partition , int msgflags , Pointer <rd_kafka_message_t rkmessages , int message_cnt → int
@brief Produce multiple messages.
rd_kafka_producev (Pointer <rd_kafka_t rk → int
@brief Produce and send a single message to broker.
rd_kafka_produceva (Pointer <rd_kafka_t rk , Pointer <rd_kafka_vu_t vus , int cnt → Pointer <rd_kafka_error_t
@brief Produce and send a single message to broker.
rd_kafka_purge (Pointer <rd_kafka_t rk , int purge_flags → int
@brief Purge messages currently handled by the producer instance.
rd_kafka_query_watermark_offsets (Pointer <rd_kafka_t rk , Pointer <Char topic , int partition , Pointer <Int64 low , Pointer <Int64 high , int timeout_ms → int
@brief Query broker for low (oldest/beginning) and high (newest/end) offsets
for partition.
rd_kafka_queue_cb_event_enable (Pointer <rd_kafka_queue_t rkqu , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Pointer <Void qev_opaque event_cb , Pointer <Void qev_opaque → void
@brief Enable callback event triggering for queue.
rd_kafka_queue_destroy (Pointer <rd_kafka_queue_t rkqu → void
Destroy a queue, purging all of its enqueued messages.
rd_kafka_queue_forward (Pointer <rd_kafka_queue_t src , Pointer <rd_kafka_queue_t dst → void
@brief Forward/re-route queue \p src to \p dst.
If \p dst is \c NULL the forwarding is removed.
rd_kafka_queue_get_background (Pointer <rd_kafka_t rk → Pointer <rd_kafka_queue_t
@returns a reference to the background thread queue, or NULL if the
background queue is not enabled.
rd_kafka_queue_get_consumer (Pointer <rd_kafka_t rk → Pointer <rd_kafka_queue_t
@returns a reference to the librdkafka consumer queue.
This is the queue served by rd_kafka_consumer_poll().
rd_kafka_queue_get_main (Pointer <rd_kafka_t rk → Pointer <rd_kafka_queue_t
@returns a reference to the main librdkafka event queue.
This is the queue served by rd_kafka_poll().
rd_kafka_queue_get_partition (Pointer <rd_kafka_t rk , Pointer <Char topic , int partition → Pointer <rd_kafka_queue_t
@returns a reference to the partition's queue, or NULL if
partition is invalid.
rd_kafka_queue_get_sasl (Pointer <rd_kafka_t rk → Pointer <rd_kafka_queue_t
@returns a reference to the SASL callback queue, if a SASL mechanism
with callbacks is configured (currently only OAUTHBEARER), else
returns NULL.
rd_kafka_queue_io_event_enable (Pointer <rd_kafka_queue_t rkqu , int fd , Pointer <Void payload , int size → void
@brief Enable IO event triggering for queue.
rd_kafka_queue_length (Pointer <rd_kafka_queue_t rkqu → int
@returns the current number of elements in queue.
rd_kafka_queue_new (Pointer <rd_kafka_t rk → Pointer <rd_kafka_queue_t
@brief Create a new message queue.
rd_kafka_queue_poll (Pointer <rd_kafka_queue_t rkqu , int timeout_ms → Pointer <rd_kafka_event_t
@brief Poll a queue for an event for max \p timeout_ms.
rd_kafka_queue_poll_callback (Pointer <rd_kafka_queue_t rkqu , int timeout_ms → int
@brief Poll a queue for events served through callbacks for max \p
timeout_ms.
rd_kafka_queue_yield (Pointer <rd_kafka_queue_t rkqu → void
@brief Cancels the current rd_kafka_queue_poll() on \p rkqu.
rd_kafka_rebalance_protocol (Pointer <rd_kafka_t rk → Pointer <Char
@brief The rebalance protocol currently in use. This will be
"NONE" if the consumer has not (yet) joined a group, else it will
match the rebalance protocol ("EAGER", "COOPERATIVE") of the
configured and selected assignor(s). All configured
assignors must have the same protocol type, meaning
online migration of a consumer group from using one
protocol to another (in particular upgading from EAGER
to COOPERATIVE) without a restart is not currently
supported.
rd_kafka_ResourcePatternType_name (int resource_pattern_type → Pointer <Char
@returns a string representation of the \p resource_pattern_type
rd_kafka_ResourceType_name (int restype → Pointer <Char
@returns a string representation of the \p restype
rd_kafka_resume_partitions (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t partitions → int
@brief Resume producing consumption for the provided list of partitions.
rd_kafka_sasl_background_callbacks_enable (Pointer <rd_kafka_t rk → Pointer <rd_kafka_error_t
@brief Enable SASL OAUTHBEARER refresh callbacks on the librdkafka
background thread.
rd_kafka_sasl_set_credentials (Pointer <rd_kafka_t rk , Pointer <Char username , Pointer <Char password → Pointer <rd_kafka_error_t
@brief Sets SASL credentials used for SASL PLAIN and SCRAM mechanisms by
this Kafka client.
rd_kafka_ScramCredentialInfo_iterations (Pointer <rd_kafka_ScramCredentialInfo_t scram_credential_info → int
@brief Returns the iterations of a given ScramCredentialInfo.
rd_kafka_ScramCredentialInfo_mechanism (Pointer <rd_kafka_ScramCredentialInfo_t scram_credential_info → int
@brief Returns the mechanism of a given ScramCredentialInfo.
rd_kafka_seek (Pointer <rd_kafka_topic_t rkt , int partition , int offset , int timeout_ms → int
@brief Seek consumer for topic+partition to \p offset which is either an
absolute or logical offset.
rd_kafka_seek_partitions (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t partitions , int timeout_ms → Pointer <rd_kafka_error_t
@brief Seek consumer for partitions in \p partitions to the per-partition
offset in the \c .offset field of \p partitions.
rd_kafka_send_offsets_to_transaction (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t offsets , Pointer <rd_kafka_consumer_group_metadata_t cgmetadata , int timeout_ms → Pointer <rd_kafka_error_t
@brief Sends a list of topic partition offsets to the consumer group
coordinator for \p cgmetadata, and marks the offsets as part
part of the current transaction.
These offsets will be considered committed only if the transaction is
committed successfully.
rd_kafka_set_log_level (Pointer <rd_kafka_t rk , int level → void
@brief Specifies the maximum logging level emitted by
internal kafka logging and debugging.
rd_kafka_set_log_queue (Pointer <rd_kafka_t rk , Pointer <rd_kafka_queue_t rkqu → int
@brief Forward librdkafka logs (and debug) to the specified queue
for serving with one of the ..poll() calls.
rd_kafka_set_logger (Pointer <rd_kafka_t rk , Pointer <NativeFunction <Void Function(Pointer <rd_kafka_t rk , Int level , Pointer <Char fac , Pointer <Char buf func → void
@brief Set logger function.
rd_kafka_subscribe (Pointer <rd_kafka_t rk , Pointer <rd_kafka_topic_partition_list_t topics → int
@brief Subscribe to topic set using balanced consumer groups.
rd_kafka_subscription (Pointer <rd_kafka_t rk , Pointer <Pointer <rd_kafka_topic_partition_list_t topics → int
@brief Returns the current topic subscription
rd_kafka_test_fatal_error (Pointer <rd_kafka_t rk , int err , Pointer <Char reason → int
@brief Trigger a fatal error for testing purposes.
rd_kafka_thread_cnt ()
→ int
@brief Retrieve the current number of threads in use by librdkafka.
rd_kafka_topic_conf_destroy (Pointer <rd_kafka_topic_conf_t topic_conf → void
@brief Destroys a topic conf object.
rd_kafka_topic_conf_dump (Pointer <rd_kafka_topic_conf_t conf , Pointer <Size cntp → Pointer <Pointer <Char
@brief Dump the topic configuration properties and values of \p conf
to an array with "key", "value" pairs.
rd_kafka_topic_conf_dup (Pointer <rd_kafka_topic_conf_t conf → Pointer <rd_kafka_topic_conf_t
@brief Creates a copy/duplicate of topic configuration object \p conf.
rd_kafka_topic_conf_get (Pointer <rd_kafka_topic_conf_t conf , Pointer <Char name , Pointer <Char dest , Pointer <Size dest_size → int
@brief Retrieve topic configuration value for property \p name.
rd_kafka_topic_conf_new ()
→ Pointer <rd_kafka_topic_conf_t
@brief Create topic configuration object
rd_kafka_topic_conf_set (Pointer <rd_kafka_topic_conf_t conf , Pointer <Char name , Pointer <Char value , Pointer <Char errstr , int errstr_size → int
@brief Sets a single rd_kafka_topic_conf_t value by property name.
rd_kafka_topic_conf_set_msg_order_cmp (Pointer <rd_kafka_topic_conf_t topic_conf , Pointer <NativeFunction <Int Function(Pointer <rd_kafka_message_t a , Pointer <rd_kafka_message_t b msg_order_cmp → void
@brief \b Producer: Set message queueing order comparator callback.
rd_kafka_topic_conf_set_opaque (Pointer <rd_kafka_topic_conf_t conf , Pointer <Void rkt_opaque → void
@brief Sets the application's opaque pointer that will be passed to all topic
callbacks as the \c rkt_opaque argument.
rd_kafka_topic_conf_set_partitioner_cb (Pointer <rd_kafka_topic_conf_t topic_conf , Pointer <NativeFunction <Int32 Function(Pointer <rd_kafka_topic_t rkt , Pointer <Void keydata , Size keylen , Int32 partition_cnt , Pointer <Void rkt_opaque , Pointer <Void msg_opaque partitioner → void
@brief \b Producer: Set partitioner callback in provided topic conf object.
rd_kafka_topic_destroy (Pointer <rd_kafka_topic_t rkt → void
@brief Loose application's topic handle refcount as previously created
with rd_kafka_topic_new().
rd_kafka_topic_name (Pointer <rd_kafka_topic_t rkt → Pointer <Char
@brief Returns the topic name.
rd_kafka_topic_new (Pointer <rd_kafka_t rk , Pointer <Char topic , Pointer <rd_kafka_topic_conf_t conf → Pointer <rd_kafka_topic_t
@brief Creates a new topic handle for topic named \p topic.
rd_kafka_topic_opaque (Pointer <rd_kafka_topic_t rkt → Pointer <Void
@brief Get the \p rkt_opaque pointer that was set in the topic configuration
with rd_kafka_topic_conf_set_opaque().
rd_kafka_topic_partition_available (Pointer <rd_kafka_topic_t rkt , int partition → int
@brief Check if partition is available (has a leader broker).
rd_kafka_topic_partition_destroy (Pointer <rd_kafka_topic_partition_t rktpar → void
@brief Destroy a rd_kafka_topic_partition_t.
@remark This must not be called for elements in a topic partition list.
rd_kafka_topic_partition_get_leader_epoch (Pointer <rd_kafka_topic_partition_t rktpar → int
@returns the offset leader epoch, if relevant and known,
else -1.
rd_kafka_topic_partition_list_add (Pointer <rd_kafka_topic_partition_list_t rktparlist , Pointer <Char topic , int partition → Pointer <rd_kafka_topic_partition_t
@brief Add topic+partition to list
rd_kafka_topic_partition_list_add_range (Pointer <rd_kafka_topic_partition_list_t rktparlist , Pointer <Char topic , int start , int stop → void
@brief Add range of partitions from \p start to \p stop inclusive.
rd_kafka_topic_partition_list_copy (Pointer <rd_kafka_topic_partition_list_t src → Pointer <rd_kafka_topic_partition_list_t
@brief Make a copy of an existing list.
rd_kafka_topic_partition_list_del (Pointer <rd_kafka_topic_partition_list_t rktparlist , Pointer <Char topic , int partition → int
@brief Delete partition from list.
rd_kafka_topic_partition_list_del_by_idx (Pointer <rd_kafka_topic_partition_list_t rktparlist , int idx → int
@brief Delete partition from list by elems[] index.
rd_kafka_topic_partition_list_destroy (Pointer <rd_kafka_topic_partition_list_t rkparlist → void
@brief Free all resources used by the list and the list itself.
rd_kafka_topic_partition_list_find (Pointer <rd_kafka_topic_partition_list_t rktparlist , Pointer <Char topic , int partition → Pointer <rd_kafka_topic_partition_t
@brief Find element by \p topic and \p partition.
rd_kafka_topic_partition_list_new (int size → Pointer <rd_kafka_topic_partition_list_t
@brief Create a new list/vector Topic+Partition container.
rd_kafka_topic_partition_list_set_offset (Pointer <rd_kafka_topic_partition_list_t rktparlist , Pointer <Char topic , int partition , int offset → int
@brief Set offset to \p offset for \p topic and \p partition
rd_kafka_topic_partition_list_sort (Pointer <rd_kafka_topic_partition_list_t rktparlist , Pointer <NativeFunction <Int Function(Pointer <Void a , Pointer <Void b , Pointer <Void cmp_opaque cmp , Pointer <Void cmp_opaque → void
@brief Sort list using comparator \p cmp.
rd_kafka_topic_partition_result_error (Pointer <rd_kafka_topic_partition_result_t partition_result → Pointer <rd_kafka_error_t
@returns the error object from the topic partition result object.
@remarks lifetime of the returned string is the same as the \p
partition_result.
rd_kafka_topic_partition_result_partition (Pointer <rd_kafka_topic_partition_result_t partition_result → Pointer <rd_kafka_topic_partition_t
@returns the topic partition object from the topic partition result object.
@remarks lifetime of the returned string is the same as the \p
partition_result.
The error object is set inside the topic partition object. For the
detailed error information, use
rd_kafka_topic_partition_result_error()
rd_kafka_topic_partition_set_leader_epoch (Pointer <rd_kafka_topic_partition_t rktpar , int leader_epoch → void
@brief Sets the offset leader epoch (use -1 to clear).
rd_kafka_topic_result_error (Pointer <rd_kafka_topic_result_t topicres → int
@returns the error code for the given topic result.
rd_kafka_topic_result_error_string (Pointer <rd_kafka_topic_result_t topicres → Pointer <Char
@returns the human readable error string for the given topic result,
or NULL if there was no error.
rd_kafka_topic_result_name (Pointer <rd_kafka_topic_result_t topicres → Pointer <Char
@returns the name of the topic for the given topic result.
@remark lifetime of the returned string is the same as the \p topicres.
rd_kafka_TopicCollection_destroy (Pointer <rd_kafka_TopicCollection_t topics → void
@brief Destroy and free a TopicCollection object created with
rd_kafka_TopicCollection_new_* methods.
rd_kafka_TopicCollection_of_topic_names (Pointer <Pointer <Char topics , int topics_cnt → Pointer <rd_kafka_TopicCollection_t
@brief Creates a new TopicCollection for passing to rd_kafka_DescribeTopics.
rd_kafka_TopicDescription_authorized_operations (Pointer <rd_kafka_TopicDescription_t topicdesc , Pointer <Size cntp → Pointer <Int32
@brief Gets the topic authorized ACL operations for the \p topicdesc topic.
rd_kafka_TopicDescription_error (Pointer <rd_kafka_TopicDescription_t topicdesc → Pointer <rd_kafka_error_t
@brief Gets the error for the \p topicdesc topic.
rd_kafka_TopicDescription_is_internal (Pointer <rd_kafka_TopicDescription_t topicdesc → int
@brief Gets if the \p topicdesc topic is internal.
rd_kafka_TopicDescription_name (Pointer <rd_kafka_TopicDescription_t topicdesc → Pointer <Char
@brief Gets the topic name for the \p topicdesc topic.
rd_kafka_TopicDescription_partitions (Pointer <rd_kafka_TopicDescription_t topicdesc , Pointer <Size cntp → Pointer <Pointer <rd_kafka_TopicPartitionInfo_t
@brief Gets an array of partitions for the \p topicdesc topic.
rd_kafka_TopicDescription_topic_id (Pointer <rd_kafka_TopicDescription_t topicdesc → Pointer <rd_kafka_Uuid_t
@brief Gets the topic id for the \p topicdesc topic.
rd_kafka_TopicPartitionInfo_isr (Pointer <rd_kafka_TopicPartitionInfo_t partition , Pointer <Size cntp → Pointer <Pointer <rd_kafka_Node_t
@brief Gets the partition in-sync replicas for \p partition.
rd_kafka_TopicPartitionInfo_leader (Pointer <rd_kafka_TopicPartitionInfo_t partition → Pointer <rd_kafka_Node_t
@brief Gets the partition leader for \p partition.
rd_kafka_TopicPartitionInfo_partition (Pointer <rd_kafka_TopicPartitionInfo_t partition → int
@brief Gets the partition id for \p partition.
rd_kafka_TopicPartitionInfo_replicas (Pointer <rd_kafka_TopicPartitionInfo_t partition , Pointer <Size cntp → Pointer <Pointer <rd_kafka_Node_t
@brief Gets the partition replicas for \p partition.
rd_kafka_type (Pointer <rd_kafka_t rk → int
@brief Returns Kafka handle type.
rd_kafka_unittest ()
→ int
@brief Run librdkafka's built-in unit-tests.
rd_kafka_unsubscribe (Pointer <rd_kafka_t rk → int
@brief Unsubscribe from the current subscription set.
rd_kafka_UserScramCredentialAlteration_destroy (Pointer <rd_kafka_UserScramCredentialAlteration_t alteration → void
@brief Destroys a UserScramCredentialAlteration given its pointer
rd_kafka_UserScramCredentialAlteration_destroy_array (Pointer <Pointer <rd_kafka_UserScramCredentialAlteration_t alterations , int alteration_cnt → void
@brief Destroys an array of UserScramCredentialAlteration
rd_kafka_UserScramCredentialDeletion_new (Pointer <Char username , int mechanism → Pointer <rd_kafka_UserScramCredentialAlteration_t
@brief Allocates a new UserScramCredentialDeletion given its fields.
rd_kafka_UserScramCredentialsDescription_error (Pointer <rd_kafka_UserScramCredentialsDescription_t description → Pointer <rd_kafka_error_t
@brief Returns the error associated with a UserScramCredentialsDescription.
rd_kafka_UserScramCredentialsDescription_scramcredentialinfo (Pointer <rd_kafka_UserScramCredentialsDescription_t description , int idx → Pointer <rd_kafka_ScramCredentialInfo_t
@brief Returns the ScramCredentialInfo at index idx of
UserScramCredentialsDescription.
rd_kafka_UserScramCredentialsDescription_scramcredentialinfo_count (Pointer <rd_kafka_UserScramCredentialsDescription_t description → int
@brief Returns the count of ScramCredentialInfos of a
UserScramCredentialsDescription.
rd_kafka_UserScramCredentialsDescription_user (Pointer <rd_kafka_UserScramCredentialsDescription_t description → Pointer <Char
@brief Returns the username of a UserScramCredentialsDescription.
rd_kafka_UserScramCredentialUpsertion_new (Pointer <Char username , int mechanism , int iterations , Pointer <UnsignedChar password , int password_size , Pointer <UnsignedChar salt , int salt_size → Pointer <rd_kafka_UserScramCredentialAlteration_t
@brief Allocates a new UserScramCredentialUpsertion given its fields.
If salt isn't given a 64 B salt is generated using OpenSSL
RAND_priv_bytes, if available.
rd_kafka_Uuid_base64str (Pointer <rd_kafka_Uuid_t uuid → Pointer <Char
@brief Computes base64 encoding for the given uuid string.
@param uuid UUID for which base64 encoding is required.
rd_kafka_Uuid_copy (Pointer <rd_kafka_Uuid_t uuid → Pointer <rd_kafka_Uuid_t
@brief Copies the given UUID.
rd_kafka_Uuid_destroy (Pointer <rd_kafka_Uuid_t uuid → void
@brief Destroy the provided uuid.
rd_kafka_Uuid_least_significant_bits (Pointer <rd_kafka_Uuid_t uuid → int
@brief Gets least significant 64 bits for the given UUID.
rd_kafka_Uuid_most_significant_bits (Pointer <rd_kafka_Uuid_t uuid → int
@brief Gets most significant 64 bits for the given UUID.
rd_kafka_Uuid_new (int most_significant_bits , int least_significant_bits → Pointer <rd_kafka_Uuid_t
@brief Creates a new UUID.
rd_kafka_version ()
→ int
@brief Returns the librdkafka version as integer.
rd_kafka_version_str ()
→ Pointer <Char
@brief Returns the librdkafka version as string.
rd_kafka_wait_destroyed (int timeout_ms → int
@brief Wait for all rd_kafka_t objects to be destroyed.
rd_kafka_yield (Pointer <rd_kafka_t rk → void
@brief Cancels the current callback dispatcher (rd_kafka_poll(),
rd_kafka_consume_callback(), etc).
recv (int arg0 , Pointer <Void arg1 , int arg2 , int arg3 → int
recvfrom (int arg0 , Pointer <Void arg1 , int arg2 , int arg3 , Pointer <sockaddr arg4 , Pointer <socklen_t arg5 → int
recvmsg (int arg0 , Pointer <msghdr arg1 , int arg2 → int
remove (Pointer <Char arg0 → int
rename (Pointer <Char __old , Pointer <Char __new → int
renameat (int arg0 , Pointer <Char arg1 , int arg2 , Pointer <Char arg3 → int
renameatx_np (int arg0 , Pointer <Char arg1 , int arg2 , Pointer <Char arg3 , int arg4 → int
renamex_np (Pointer <Char arg0 , Pointer <Char arg1 , int arg2 → int
rewind (Pointer <FILE arg0 → void
scanf (Pointer <Char arg0 → int
send (int arg0 , Pointer <Void arg1 , int arg2 , int arg3 → int
sendfile (int arg0 , int arg1 , int arg2 , Pointer <off_t arg3 , Pointer <sf_hdtr arg4 , int arg5 → int
sendmsg (int arg0 , Pointer <msghdr arg1 , int arg2 → int
sendto (int arg0 , Pointer <Void arg1 , int arg2 , int arg3 , Pointer <sockaddr arg4 , int arg5 → int
setbuf (Pointer <FILE arg0 , Pointer <Char arg1 → void
setbuffer (Pointer <FILE arg0 , Pointer <Char arg1 , int arg2 → void
setlinebuf (Pointer <FILE arg0 → int
setsockopt (int arg0 , int arg1 , int arg2 , Pointer <Void arg3 , int arg4 → int
setvbuf (Pointer <FILE arg0 , Pointer <Char arg1 , int arg2 , int arg3 → int
shutdown (int arg0 , int arg1 → int
snprintf (Pointer <Char __str , int __size , Pointer <Char __format → int
sockatmark (int arg0 → int
socket (int arg0 , int arg1 , int arg2 → int
socketpair (int arg0 , int arg1 , int arg2 , Pointer <Int arg3 → int
sprintf (Pointer <Char arg0 , Pointer <Char arg1 → int
sscanf (Pointer <Char arg0 , Pointer <Char arg1 → int
strtoimax (Pointer <Char __nptr , Pointer <Pointer <Char __endptr , int __base → int
strtoumax (Pointer <Char __nptr , Pointer <Pointer <Char __endptr , int __base → int
tempnam (Pointer <Char __dir , Pointer <Char __prefix → Pointer <Char
tmpfile ()
→ Pointer <FILE
tmpnam (Pointer <Char arg0 → Pointer <Char
toString ()
→ String
A string representation of this object.
inherited
ungetc (int arg0 , Pointer <FILE arg1 → int
vasprintf (Pointer <Pointer <Char arg0 , Pointer <Char arg1 , va_list arg2 → int
vdprintf (int arg0 , Pointer <Char arg1 , va_list arg2 → int
vfprintf (Pointer <FILE arg0 , Pointer <Char arg1 , va_list arg2 → int
vfscanf (Pointer <FILE __stream , Pointer <Char __format , va_list arg2 → int
vprintf (Pointer <Char arg0 , va_list arg1 → int
vscanf (Pointer <Char __format , va_list arg1 → int
vsnprintf (Pointer <Char __str , int __size , Pointer <Char __format , va_list arg3 → int
vsprintf (Pointer <Char arg0 , Pointer <Char arg1 , va_list arg2 → int
vsscanf (Pointer <Char __str , Pointer <Char __format , va_list arg2 → int
wcstoimax (Pointer <WChar __nptr , Pointer <Pointer <WChar __endptr , int __base → int
wcstoumax (Pointer <WChar __nptr , Pointer <Pointer <WChar __endptr , int __base → int
