librdkafka v0.1.0 (2016-03-31T08:40:23Z)
Home
Dub
Repo
rd_kafka_conf_set_rebalance_cb
deimos
librdkafka
Undocumented in source but is binding to C. You might be able to learn more by searching the web for its name.
extern (
C
)
void
rd_kafka_conf_set_rebalance_cb
(
rd_kafka_conf_t
*
conf
,
rebalance_cb_callback
rebalance_cb
)
Meta
Source
See Implementation
deimos
librdkafka
aliases
dr_cb_callback
dr_msg_cb_callback
error_cb_callback
func_callback
log_cb_callback
offset_commit_cb_call_back
open_cb_callback
partitioner_callback
rd_kafka_conf_t
rd_kafka_message_t
rd_kafka_metadata_broker_t
rd_kafka_metadata_partition_t
rd_kafka_metadata_topic_t
rd_kafka_queue_t
rd_kafka_t
rd_kafka_topic_conf_t
rd_kafka_topic_partition_list_t
rd_kafka_topic_partition_t
rd_kafka_topic_t
rebalance_cb_callback
socket_cb_callback
stats_cb_callback
throttle_cb_callback
enums
rd_kafka_conf_res_t
rd_kafka_resp_err_t
rd_kafka_type_t
functions
RD_KAFKA_OFFSET_TAIL
rd_kafka_assign
rd_kafka_assignment
rd_kafka_brokers_add
rd_kafka_commit
rd_kafka_commit_message
rd_kafka_conf_destroy
rd_kafka_conf_dump
rd_kafka_conf_dump_free
rd_kafka_conf_dup
rd_kafka_conf_get
rd_kafka_conf_new
rd_kafka_conf_properties_show
rd_kafka_conf_set
rd_kafka_conf_set_consume_cb
rd_kafka_conf_set_default_topic_conf
rd_kafka_conf_set_dr_cb
rd_kafka_conf_set_dr_msg_cb
rd_kafka_conf_set_error_cb
rd_kafka_conf_set_log_cb
rd_kafka_conf_set_offset_commit_cb
rd_kafka_conf_set_opaque
rd_kafka_conf_set_open_cb
rd_kafka_conf_set_rebalance_cb
rd_kafka_conf_set_socket_cb
rd_kafka_conf_set_stats_cb
rd_kafka_conf_set_throttle_cb
rd_kafka_consume
rd_kafka_consume_batch
rd_kafka_consume_batch_queue
rd_kafka_consume_callback
rd_kafka_consume_callback_queue
rd_kafka_consume_queue
rd_kafka_consume_start
rd_kafka_consume_start_queue
rd_kafka_consume_stop
rd_kafka_consumer_close
rd_kafka_consumer_poll
rd_kafka_destroy
rd_kafka_dump
rd_kafka_err2name
rd_kafka_err2str
rd_kafka_errno
rd_kafka_errno2err
rd_kafka_get_debug_contexts
rd_kafka_get_err_descs
rd_kafka_get_watermark_offsets
rd_kafka_group_list_destroy
rd_kafka_last_error
rd_kafka_list_groups
rd_kafka_log_print
rd_kafka_log_syslog
rd_kafka_mem_free
rd_kafka_memberid
rd_kafka_message_destroy
rd_kafka_message_errstr
rd_kafka_metadata
rd_kafka_metadata_destroy
rd_kafka_msg_partitioner_consistent
rd_kafka_msg_partitioner_consistent_random
rd_kafka_msg_partitioner_random
rd_kafka_name
rd_kafka_new
rd_kafka_offset_store
rd_kafka_opaque
rd_kafka_outq_len
rd_kafka_pause_partitions
rd_kafka_poll
rd_kafka_poll_set_consumer
rd_kafka_position
rd_kafka_produce
rd_kafka_produce_batch
rd_kafka_query_watermark_offsets
rd_kafka_queue_destroy
rd_kafka_queue_new
rd_kafka_resume_partitions
rd_kafka_seek
rd_kafka_set_log_level
rd_kafka_set_logger
rd_kafka_subscribe
rd_kafka_subscription
rd_kafka_thread_cnt
rd_kafka_topic_conf_destroy
rd_kafka_topic_conf_dump
rd_kafka_topic_conf_dup
rd_kafka_topic_conf_get
rd_kafka_topic_conf_new
rd_kafka_topic_conf_set
rd_kafka_topic_conf_set_opaque
rd_kafka_topic_conf_set_partitioner_cb
rd_kafka_topic_destroy
rd_kafka_topic_name
rd_kafka_topic_new
rd_kafka_topic_opaque
rd_kafka_topic_partition_available
rd_kafka_topic_partition_list_add
rd_kafka_topic_partition_list_add_range
rd_kafka_topic_partition_list_copy
rd_kafka_topic_partition_list_destroy
rd_kafka_topic_partition_list_find
rd_kafka_topic_partition_list_new
rd_kafka_topic_partition_list_set_offset
rd_kafka_unsubscribe
rd_kafka_version
rd_kafka_version_str
rd_kafka_wait_destroyed
rd_kafka_yield
manifest constants
RD_KAFKA_DEBUG_CONTEXTS
RD_KAFKA_MSG_F_COPY
RD_KAFKA_MSG_F_FREE
RD_KAFKA_OFFSET_BEGINNING
RD_KAFKA_OFFSET_END
RD_KAFKA_OFFSET_INVALID
RD_KAFKA_OFFSET_STORED
RD_KAFKA_OFFSET_TAIL_BASE
RD_KAFKA_VERSION
structs
rd_kafka_conf_s
rd_kafka_err_desc
rd_kafka_group_info
rd_kafka_group_list
rd_kafka_group_member_info
rd_kafka_message_s
rd_kafka_metadata_broker
rd_kafka_metadata_partition
rd_kafka_metadata_t
rd_kafka_metadata_topic
rd_kafka_queue_s
rd_kafka_s
rd_kafka_topic_conf_s
rd_kafka_topic_partition_list_s
rd_kafka_topic_partition_s
rd_kafka_topic_s