librdkafka/generated_bindings.g library

Classes

addrinfo
Forward declaration to avoid netdb.h or winsock includes
cmsghdr
fd_set
imaxdiv_t
iovec
LibRdKafka
linger
msghdr
rd_kafka_acl_result_s
rd_kafka_AclBinding_s
rd_kafka_AclOperation_t
@enum rd_kafka_AclOperation_t @brief Apache Kafka ACL operation types. Common type for multiple Admin API functions.
rd_kafka_AclPermissionType_t
@enum rd_kafka_AclPermissionType_t @brief Apache Kafka ACL permission types.
rd_kafka_admin_op_t
@enum rd_kafka_admin_op_t
rd_kafka_AdminOptions_s
rd_kafka_AlterConfigOpType_t
@enum rd_kafka_AlterConfigOpType_t @brief Incremental alter configs operations.
rd_kafka_AlterConsumerGroupOffsets_s
rd_kafka_AlterUserScramCredentials_result_response_s
rd_kafka_cert_enc_t
@enum rd_kafka_cert_enc_t
rd_kafka_cert_type_t
@enum rd_kafka_cert_type_t
rd_kafka_conf_res_t
@enum rd_kafka_conf_res_t @brief Configuration result type
rd_kafka_conf_s
rd_kafka_ConfigEntry_s
rd_kafka_ConfigResource_s
rd_kafka_ConfigSource_t
@enum rd_kafka_ConfigSource_t
rd_kafka_consumer_group_metadata_s
rd_kafka_consumer_group_state_t
@enum rd_kafka_consumer_group_state_t
rd_kafka_consumer_group_type_t
@enum rd_kafka_consumer_group_type_t
rd_kafka_ConsumerGroupDescription_s
rd_kafka_ConsumerGroupListing_s
rd_kafka_DeleteAcls_result_response_s
rd_kafka_DeleteConsumerGroupOffsets_s
rd_kafka_DeleteGroup_s
rd_kafka_DeleteRecords_s
rd_kafka_DeleteTopic_s
rd_kafka_ElectionType_t
@enum rd_kafka_ElectionType_t @brief Apache Kafka Election Types
rd_kafka_ElectLeaders_s
rd_kafka_err_desc
@brief Error code value, name and description. Typically for use with language bindings to automatically expose the full set of librdkafka error codes.
rd_kafka_error_s
rd_kafka_group_info
@brief Group information
rd_kafka_group_list
@brief List of groups
rd_kafka_group_member_info
@brief Group member information
rd_kafka_group_result_s
rd_kafka_headers_s
rd_kafka_IsolationLevel_t
@enum rd_kafka_IsolationLevel_t
rd_kafka_ListConsumerGroupOffsets_s
rd_kafka_ListConsumerGroupsResult_s
rd_kafka_ListOffsetsResultInfo_s
rd_kafka_MemberAssignment_s
rd_kafka_MemberDescription_s
rd_kafka_message_s
@brief A Kafka message as returned by the \c rd_kafka_consume*() family of functions as well as provided to the Producer \c dr_msg_cb().
rd_kafka_metadata
@brief Metadata container
rd_kafka_metadata_broker
@brief Broker information
rd_kafka_metadata_partition
@brief Partition information
rd_kafka_metadata_topic
@brief Topic information
rd_kafka_msg_status_t
@enum rd_kafka_msg_status_t @brief Message persistence status can be used by the application to find out if a produced message was persisted in the topic log.
rd_kafka_NewPartitions_s
rd_kafka_NewTopic_s
rd_kafka_Node_s
rd_kafka_OffsetSpec_t
@enum rd_kafka_OffsetSpec_t @brief Allows to specify the desired offsets when using ListOffsets.
rd_kafka_op_s
rd_kafka_queue_s
rd_kafka_ResourcePatternType_t
@enum rd_kafka_ResourcePatternType_t @brief Apache Kafka pattern types
rd_kafka_ResourceType_t
@enum rd_kafka_ResourceType_t @brief Apache Kafka resource types
rd_kafka_resp_err_t
@enum rd_kafka_resp_err_t @brief Error codes.
rd_kafka_s
rd_kafka_ScramCredentialInfo_s
rd_kafka_ScramMechanism_t
@enum rd_kafka_ScramMechanism_t @brief Apache Kafka ScramMechanism values.
rd_kafka_thread_type_t
@enum rd_kafka_thread_type_t
rd_kafka_timestamp_type_t
! Timestamp types
rd_kafka_topic_conf_s
rd_kafka_topic_partition_list_s
@brief A growable list of Topic+Partitions.
rd_kafka_topic_partition_result_s
rd_kafka_topic_partition_s
@brief Generic place holder for a specific Topic+Partition.
rd_kafka_topic_result_s
rd_kafka_topic_s
rd_kafka_TopicCollection_s
rd_kafka_TopicDescription_s
rd_kafka_TopicPartitionInfo_s
rd_kafka_type_t
@enum rd_kafka_type_t
rd_kafka_UserScramCredentialAlteration_s
rd_kafka_UserScramCredentialsDescription_s
rd_kafka_Uuid_s
rd_kafka_vtype_t
@enum rd_kafka_vtype_t
rd_kafka_vu_s
@brief VTYPE + argument container for use with rd_kafka_produce_va()
sa_endpoints
sf_hdtr
so_np_extensions
sockaddr
sockaddr_storage
sockproto
UnnamedStruct1
UnnamedStruct2
UnnamedUnion1
Value union, see RD_KAFKA_V_.. macros for which field to use.

Constants

AF_APPLETALK → const int
AF_CCITT → const int
AF_CHAOS → const int
AF_CNT → const int
AF_COIP → const int
AF_DATAKIT → const int
AF_DECnet → const int
AF_DLI → const int
AF_E164 → const int
AF_ECMA → const int
AF_IEEE80211 → const int
AF_INET → const int
AF_INET6 → const int
AF_IPX → const int
AF_ISDN → const int
AF_ISO → const int
AF_LAT → const int
AF_LOCAL → const int
AF_MAX → const int
AF_NATM → const int
AF_NDRV → const int
AF_NETBIOS → const int
AF_NS → const int
AF_OSI → const int
AF_PPP → const int
AF_PUP → const int
AF_RESERVED_36 → const int
AF_ROUTE → const int
AF_SIP → const int
AF_SNA → const int
AF_SYSTEM → const int
AF_UNIX → const int
AF_UNSPEC → const int
AF_UTUN → const int
AF_VSOCK → const int
BIG_ENDIAN → const int
BUFSIZ → const int
BYTE_ORDER → const int
CONNECT_DATA_AUTHENTICATED → const int
CONNECT_DATA_IDEMPOTENT → const int
CONNECT_RESUME_ON_READ_WRITE → const int
EOF → const int
FD_SETSIZE → const int
FILENAME_MAX → const int
FOPEN_MAX → const int
INT16_MAX → const int
INT16_MIN → const int
INT32_MAX → const int
INT32_MIN → const int
INT64_MAX → const int
INT64_MIN → const int
INT8_MAX → const int
INT8_MIN → const int
INT_FAST16_MAX → const int
INT_FAST16_MIN → const int
INT_FAST32_MAX → const int
INT_FAST32_MIN → const int
INT_FAST64_MAX → const int
INT_FAST64_MIN → const int
INT_FAST8_MAX → const int
INT_FAST8_MIN → const int
INT_LEAST16_MAX → const int
INT_LEAST16_MIN → const int
INT_LEAST32_MAX → const int
INT_LEAST32_MIN → const int
INT_LEAST64_MAX → const int
INT_LEAST64_MIN → const int
INT_LEAST8_MAX → const int
INT_LEAST8_MIN → const int
INTMAX_MAX → const int
INTMAX_MIN → const int
INTPTR_MAX → const int
INTPTR_MIN → const int
KEV_DL_ADDMULTI → const int
KEV_DL_AWDL_RESTRICTED → const int
KEV_DL_AWDL_UNRESTRICTED → const int
KEV_DL_DELMULTI → const int
KEV_DL_IF_ATTACHED → const int
KEV_DL_IF_DETACHED → const int
KEV_DL_IF_DETACHING → const int
KEV_DL_IF_IDLE_ROUTE_REFCNT → const int
KEV_DL_IFCAP_CHANGED → const int
KEV_DL_IFDELEGATE_CHANGED → const int
KEV_DL_ISSUES → const int
KEV_DL_LOW_POWER_MODE_CHANGED → const int
KEV_DL_MASTER_ELECTED → const int
KEV_DL_NODE_ABSENCE → const int
KEV_DL_NODE_PRESENCE → const int
KEV_DL_PRIMARY_ELECTED → const int
KEV_DL_PROTO_ATTACHED → const int
KEV_DL_PROTO_DETACHED → const int
KEV_DL_QOS_MODE_CHANGED → const int
KEV_DL_RRC_STATE_CHANGED → const int
KEV_DL_SIFFLAGS → const int
KEV_DL_SIFGENERIC → const int
KEV_DL_SIFMEDIA → const int
KEV_DL_SIFMETRICS → const int
KEV_DL_SIFMTU → const int
KEV_DL_SIFPHYS → const int
KEV_DL_SUBCLASS → const int
KEV_DL_WAKEFLAGS_CHANGED → const int
KEV_INET6_ADDR_DELETED → const int
KEV_INET6_CHANGED_ADDR → const int
KEV_INET6_DEFROUTER → const int
KEV_INET6_NEW_LL_ADDR → const int
KEV_INET6_NEW_RTADV_ADDR → const int
KEV_INET6_NEW_USER_ADDR → const int
KEV_INET6_REQUEST_NAT64_PREFIX → const int
KEV_INET6_SUBCLASS → const int
KEV_INET_ADDR_DELETED → const int
KEV_INET_ARPCOLLISION → const int
KEV_INET_ARPRTRALIVE → const int
KEV_INET_ARPRTRFAILURE → const int
KEV_INET_CHANGED_ADDR → const int
KEV_INET_NEW_ADDR → const int
KEV_INET_PORTINUSE → const int
KEV_INET_SIFBRDADDR → const int
KEV_INET_SIFDSTADDR → const int
KEV_INET_SIFNETMASK → const int
KEV_INET_SUBCLASS → const int
L_ctermid → const int
L_tmpnam → const int
LIBRDKAFKA_TYPECHECKS → const int
LITTLE_ENDIAN → const int
MAC_OS_VERSION_11_0 → const int
MAC_OS_VERSION_11_1 → const int
MAC_OS_VERSION_11_3 → const int
MAC_OS_VERSION_11_4 → const int
MAC_OS_VERSION_11_5 → const int
MAC_OS_VERSION_11_6 → const int
MAC_OS_VERSION_12_0 → const int
MAC_OS_VERSION_12_1 → const int
MAC_OS_VERSION_12_2 → const int
MAC_OS_VERSION_12_3 → const int
MAC_OS_VERSION_12_4 → const int
MAC_OS_VERSION_12_5 → const int
MAC_OS_VERSION_12_6 → const int
MAC_OS_VERSION_12_7 → const int
MAC_OS_VERSION_13_0 → const int
MAC_OS_VERSION_13_1 → const int
MAC_OS_VERSION_13_2 → const int
MAC_OS_VERSION_13_3 → const int
MAC_OS_VERSION_13_4 → const int
MAC_OS_VERSION_13_5 → const int
MAC_OS_VERSION_13_6 → const int
MAC_OS_VERSION_14_0 → const int
MAC_OS_VERSION_14_1 → const int
MAC_OS_VERSION_14_2 → const int
MAC_OS_VERSION_14_3 → const int
MAC_OS_VERSION_14_4 → const int
MAC_OS_VERSION_14_5 → const int
MAC_OS_VERSION_15_0 → const int
MAC_OS_VERSION_15_1 → const int
MAC_OS_X_VERSION_10_0 → const int
MAC_OS_X_VERSION_10_1 → const int
MAC_OS_X_VERSION_10_10 → const int
MAC_OS_X_VERSION_10_10_2 → const int
MAC_OS_X_VERSION_10_10_3 → const int
MAC_OS_X_VERSION_10_11 → const int
MAC_OS_X_VERSION_10_11_2 → const int
MAC_OS_X_VERSION_10_11_3 → const int
MAC_OS_X_VERSION_10_11_4 → const int
MAC_OS_X_VERSION_10_12 → const int
MAC_OS_X_VERSION_10_12_1 → const int
MAC_OS_X_VERSION_10_12_2 → const int
MAC_OS_X_VERSION_10_12_4 → const int
MAC_OS_X_VERSION_10_13 → const int
MAC_OS_X_VERSION_10_13_1 → const int
MAC_OS_X_VERSION_10_13_2 → const int
MAC_OS_X_VERSION_10_13_4 → const int
MAC_OS_X_VERSION_10_14 → const int
MAC_OS_X_VERSION_10_14_1 → const int
MAC_OS_X_VERSION_10_14_4 → const int
MAC_OS_X_VERSION_10_14_5 → const int
MAC_OS_X_VERSION_10_14_6 → const int
MAC_OS_X_VERSION_10_15 → const int
MAC_OS_X_VERSION_10_15_1 → const int
MAC_OS_X_VERSION_10_15_4 → const int
MAC_OS_X_VERSION_10_16 → const int
MAC_OS_X_VERSION_10_2 → const int
MAC_OS_X_VERSION_10_3 → const int
MAC_OS_X_VERSION_10_4 → const int
MAC_OS_X_VERSION_10_5 → const int
MAC_OS_X_VERSION_10_6 → const int
MAC_OS_X_VERSION_10_7 → const int
MAC_OS_X_VERSION_10_8 → const int
MAC_OS_X_VERSION_10_9 → const int
MSG_CTRUNC → const int
MSG_DONTROUTE → const int
MSG_DONTWAIT → const int
MSG_EOF → const int
MSG_EOR → const int
MSG_FLUSH → const int
MSG_HAVEMORE → const int
MSG_HOLD → const int
MSG_NEEDSA → const int
MSG_NOSIGNAL → const int
MSG_OOB → const int
MSG_PEEK → const int
MSG_RCVMORE → const int
MSG_SEND → const int
MSG_TRUNC → const int
MSG_WAITALL → const int
MSG_WAITSTREAM → const int
NBBY → const int
NET_MAXID → const int
NET_RT_DUMP → const int
NET_RT_DUMP2 → const int
NET_RT_FLAGS → const int
NET_RT_FLAGS_PRIV → const int
NET_RT_IFLIST → const int
NET_RT_IFLIST2 → const int
NET_RT_MAXID → const int
NET_RT_STAT → const int
NET_RT_TRASH → const int
NET_SERVICE_TYPE_AV → const int
NET_SERVICE_TYPE_BE → const int
NET_SERVICE_TYPE_BK → const int
NET_SERVICE_TYPE_OAM → const int
NET_SERVICE_TYPE_RD → const int
NET_SERVICE_TYPE_RV → const int
NET_SERVICE_TYPE_SIG → const int
NET_SERVICE_TYPE_VI → const int
NET_SERVICE_TYPE_VO → const int
NETSVC_MRKNG_LVL_L2 → const int
NETSVC_MRKNG_LVL_L3L2_ALL → const int
NETSVC_MRKNG_LVL_L3L2_BK → const int
NETSVC_MRKNG_UNKNOWN → const int
NFDBITS → const int
NULL → const int
P_tmpdir → const String
PDP_ENDIAN → const int
PF_APPLETALK → const int
PF_BOND → const int
PF_CCITT → const int
PF_CHAOS → const int
PF_CNT → const int
PF_COIP → const int
PF_DATAKIT → const int
PF_DECnet → const int
PF_DLI → const int
PF_ECMA → const int
PF_INET → const int
PF_INET6 → const int
PF_IPX → const int
PF_ISDN → const int
PF_ISO → const int
PF_KEY → const int
PF_LAT → const int
PF_LOCAL → const int
PF_MAX → const int
PF_NATM → const int
PF_NDRV → const int
PF_NETBIOS → const int
PF_NS → const int
PF_OSI → const int
PF_PIP → const int
PF_PPP → const int
PF_PUP → const int
PF_RESERVED_36 → const int
PF_ROUTE → const int
PF_RTIP → const int
PF_SIP → const int
PF_SNA → const int
PF_SYSTEM → const int
PF_UNIX → const int
PF_UNSPEC → const int
PF_UTUN → const int
PF_VLAN → const int
PF_VSOCK → const int
PF_XTP → const int
PRId16 → const String
PRId32 → const String
PRId64 → const String
PRId8 → const String
PRIdFAST16 → const String
PRIdFAST32 → const String
PRIdFAST64 → const String
PRIdFAST8 → const String
PRIdLEAST16 → const String
PRIdLEAST32 → const String
PRIdLEAST64 → const String
PRIdLEAST8 → const String
PRIdMAX → const String
PRIdPTR → const String
PRIi16 → const String
PRIi32 → const String
PRIi64 → const String
PRIi8 → const String
PRIiFAST16 → const String
PRIiFAST32 → const String
PRIiFAST64 → const String
PRIiFAST8 → const String
PRIiLEAST16 → const String
PRIiLEAST32 → const String
PRIiLEAST64 → const String
PRIiLEAST8 → const String
PRIiMAX → const String
PRIiPTR → const String
PRIo16 → const String
PRIo32 → const String
PRIo64 → const String
PRIo8 → const String
PRIoFAST16 → const String
PRIoFAST32 → const String
PRIoFAST64 → const String
PRIoFAST8 → const String
PRIoLEAST16 → const String
PRIoLEAST32 → const String
PRIoLEAST64 → const String
PRIoLEAST8 → const String
PRIoMAX → const String
PRIoPTR → const String
PRIu16 → const String
PRIu32 → const String
PRIu64 → const String
PRIu8 → const String
PRIuFAST16 → const String
PRIuFAST32 → const String
PRIuFAST64 → const String
PRIuFAST8 → const String
PRIuLEAST16 → const String
PRIuLEAST32 → const String
PRIuLEAST64 → const String
PRIuLEAST8 → const String
PRIuMAX → const String
PRIuPTR → const String
PRIX16 → const String
PRIx16 → const String
PRIX32 → const String
PRIx32 → const String
PRIX64 → const String
PRIx64 → const String
PRIx8 → const String
PRIX8 → const String
PRIXFAST16 → const String
PRIxFAST16 → const String
PRIXFAST32 → const String
PRIxFAST32 → const String
PRIxFAST64 → const String
PRIXFAST64 → const String
PRIXFAST8 → const String
PRIxFAST8 → const String
PRIXLEAST16 → const String
PRIxLEAST16 → const String
PRIxLEAST32 → const String
PRIXLEAST32 → const String
PRIXLEAST64 → const String
PRIxLEAST64 → const String
PRIxLEAST8 → const String
PRIXLEAST8 → const String
PRIXMAX → const String
PRIxMAX → const String
PRIXPTR → const String
PRIxPTR → const String
pseudo_AF_HDRCMPLT → const int
pseudo_AF_KEY → const int
pseudo_AF_PIP → const int
pseudo_AF_RTIP → const int
pseudo_AF_XTP → const int
PTRDIFF_MAX → const int
PTRDIFF_MIN → const int
RD_KAFKA_DEBUG_CONTEXTS → const String
RD_KAFKA_DESTROY_F_NO_CONSUMER_CLOSE → const int
RD_KAFKA_EVENT_ALTERCONFIGS_RESULT → const int
RD_KAFKA_EVENT_ALTERCONSUMERGROUPOFFSETS_RESULT → const int
RD_KAFKA_EVENT_ALTERUSERSCRAMCREDENTIALS_RESULT → const int
RD_KAFKA_EVENT_BACKGROUND → const int
RD_KAFKA_EVENT_CREATEACLS_RESULT → const int
RD_KAFKA_EVENT_CREATEPARTITIONS_RESULT → const int
RD_KAFKA_EVENT_CREATETOPICS_RESULT → const int
RD_KAFKA_EVENT_DELETEACLS_RESULT → const int
RD_KAFKA_EVENT_DELETECONSUMERGROUPOFFSETS_RESULT → const int
RD_KAFKA_EVENT_DELETEGROUPS_RESULT → const int
RD_KAFKA_EVENT_DELETERECORDS_RESULT → const int
RD_KAFKA_EVENT_DELETETOPICS_RESULT → const int
RD_KAFKA_EVENT_DESCRIBEACLS_RESULT → const int
RD_KAFKA_EVENT_DESCRIBECLUSTER_RESULT → const int
RD_KAFKA_EVENT_DESCRIBECONFIGS_RESULT → const int
RD_KAFKA_EVENT_DESCRIBECONSUMERGROUPS_RESULT → const int
RD_KAFKA_EVENT_DESCRIBETOPICS_RESULT → const int
RD_KAFKA_EVENT_DESCRIBEUSERSCRAMCREDENTIALS_RESULT → const int
RD_KAFKA_EVENT_DR → const int
RD_KAFKA_EVENT_ELECTLEADERS_RESULT → const int
RD_KAFKA_EVENT_ERROR → const int
RD_KAFKA_EVENT_FETCH → const int
RD_KAFKA_EVENT_INCREMENTALALTERCONFIGS_RESULT → const int
RD_KAFKA_EVENT_LISTCONSUMERGROUPOFFSETS_RESULT → const int
RD_KAFKA_EVENT_LISTCONSUMERGROUPS_RESULT → const int
RD_KAFKA_EVENT_LISTOFFSETS_RESULT → const int
RD_KAFKA_EVENT_LOG → const int
RD_KAFKA_EVENT_NONE → const int
RD_KAFKA_EVENT_OAUTHBEARER_TOKEN_REFRESH → const int
RD_KAFKA_EVENT_OFFSET_COMMIT → const int
RD_KAFKA_EVENT_REBALANCE → const int
RD_KAFKA_EVENT_STATS → const int
RD_KAFKA_MSG_F_BLOCK → const int
RD_KAFKA_MSG_F_COPY → const int
RD_KAFKA_MSG_F_FREE → const int
RD_KAFKA_MSG_F_PARTITION → const int
RD_KAFKA_OFFSET_BEGINNING → const int
RD_KAFKA_OFFSET_END → const int
RD_KAFKA_OFFSET_INVALID → const int
RD_KAFKA_OFFSET_STORED → const int
RD_KAFKA_OFFSET_TAIL_BASE → const int
RD_KAFKA_PARTITION_UA → const int
RD_KAFKA_PURGE_F_INFLIGHT → const int
RD_KAFKA_PURGE_F_NON_BLOCKING → const int
RD_KAFKA_PURGE_F_QUEUE → const int
RD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLE → const int
RD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESS → const int
RD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUP → const int
RD_KAFKA_RESP_ERR_NOT_LEADER_OR_FOLLOWER → const int
RD_KAFKA_V_END → const int
RD_KAFKA_VERSION → const int
RENAME_EXCL → const int
RENAME_NOFOLLOW_ANY → const int
RENAME_RESERVED1 → const int
RENAME_SECLUDE → const int
RENAME_SWAP → const int
RSIZE_MAX → const int
SAE_ASSOCID_ALL → const int
SAE_ASSOCID_ANY → const int
SAE_CONNID_ALL → const int
SAE_CONNID_ANY → const int
SCM_CREDS → const int
SCM_RIGHTS → const int
SCM_TIMESTAMP → const int
SCM_TIMESTAMP_MONOTONIC → const int
SCNd16 → const String
SCNd32 → const String
SCNd64 → const String
SCNd8 → const String
SCNdFAST16 → const String
SCNdFAST32 → const String
SCNdFAST64 → const String
SCNdFAST8 → const String
SCNdLEAST16 → const String
SCNdLEAST32 → const String
SCNdLEAST64 → const String
SCNdLEAST8 → const String
SCNdMAX → const String
SCNdPTR → const String
SCNi16 → const String
SCNi32 → const String
SCNi64 → const String
SCNi8 → const String
SCNiFAST16 → const String
SCNiFAST32 → const String
SCNiFAST64 → const String
SCNiFAST8 → const String
SCNiLEAST16 → const String
SCNiLEAST32 → const String
SCNiLEAST64 → const String
SCNiLEAST8 → const String
SCNiMAX → const String
SCNiPTR → const String
SCNo16 → const String
SCNo32 → const String
SCNo64 → const String
SCNo8 → const String
SCNoFAST16 → const String
SCNoFAST32 → const String
SCNoFAST64 → const String
SCNoFAST8 → const String
SCNoLEAST16 → const String
SCNoLEAST32 → const String
SCNoLEAST64 → const String
SCNoLEAST8 → const String
SCNoMAX → const String
SCNoPTR → const String
SCNu16 → const String
SCNu32 → const String
SCNu64 → const String
SCNu8 → const String
SCNuFAST16 → const String
SCNuFAST32 → const String
SCNuFAST64 → const String
SCNuFAST8 → const String
SCNuLEAST16 → const String
SCNuLEAST32 → const String
SCNuLEAST64 → const String
SCNuLEAST8 → const String
SCNuMAX → const String
SCNuPTR → const String
SCNx16 → const String
SCNx32 → const String
SCNx64 → const String
SCNx8 → const String
SCNxFAST16 → const String
SCNxFAST32 → const String
SCNxFAST64 → const String
SCNxFAST8 → const String
SCNxLEAST16 → const String
SCNxLEAST32 → const String
SCNxLEAST64 → const String
SCNxLEAST8 → const String
SCNxMAX → const String
SCNxPTR → const String
SEEK_CUR → const int
SEEK_DATA → const int
SEEK_END → const int
SEEK_HOLE → const int
SEEK_SET → const int
SHUT_RD → const int
SHUT_RDWR → const int
SHUT_WR → const int
SIG_ATOMIC_MAX → const int
SIG_ATOMIC_MIN → const int
SIZE_MAX → const int
SO_ACCEPTCONN → const int
SO_BINDTODEVICE → const int
SO_BROADCAST → const int
SO_DEBUG → const int
SO_DONTROUTE → const int
SO_DONTTRUNC → const int
SO_ERROR → const int
SO_KEEPALIVE → const int
SO_LABEL → const int
SO_LINGER → const int
SO_LINGER_SEC → const int
SO_NET_SERVICE_TYPE → const int
SO_NETSVC_MARKING_LEVEL → const int
SO_NKE → const int
SO_NOADDRERR → const int
SO_NOSIGPIPE → const int
SO_NOTIFYCONFLICT → const int
SO_NP_EXTENSIONS → const int
SO_NREAD → const int
SO_NUMRCVPKT → const int
SO_NWRITE → const int
SO_OOBINLINE → const int
SO_PEERLABEL → const int
SO_RANDOMPORT → const int
SO_RCVBUF → const int
SO_RCVLOWAT → const int
SO_RCVTIMEO → const int
SO_RESOLVER_SIGNATURE → const int
SO_REUSEADDR → const int
SO_REUSEPORT → const int
SO_REUSESHAREUID → const int
SO_SNDBUF → const int
SO_SNDLOWAT → const int
SO_SNDTIMEO → const int
SO_TIMESTAMP → const int
SO_TIMESTAMP_MONOTONIC → const int
SO_TYPE → const int
SO_UPCALLCLOSEWAIT → const int
SO_USELOOPBACK → const int
SO_WANTMORE → const int
SO_WANTOOBFLAG → const int
SOCK_DGRAM → const int
SOCK_MAXADDRLEN → const int
SOCK_RAW → const int
SOCK_RDM → const int
SOCK_SEQPACKET → const int
SOCK_STREAM → const int
SOL_SOCKET → const int
SOMAXCONN → const int
SONPX_SETOPTSHUT → const int
TMP_MAX → const int
UINT16_MAX → const int
UINT32_MAX → const int
UINT64_MAX → const int
UINT8_MAX → const int
UINT_FAST16_MAX → const int
UINT_FAST32_MAX → const int
UINT_FAST64_MAX → const int
UINT_FAST8_MAX → const int
UINT_LEAST16_MAX → const int
UINT_LEAST32_MAX → const int
UINT_LEAST64_MAX → const int
UINT_LEAST8_MAX → const int
UINTMAX_MAX → const int
UINTPTR_MAX → const int
USER_ADDR_NULL → const int
WCHAR_MAX → const int
WCHAR_MIN → const int
WINT_MAX → const int
WINT_MIN → const int

Typedefs

Dart__darwin_ssize_t = int
Dart__int32_t = int
Dart__int64_t = int
Dart__uint16_t = int
Dart__uint32_t = int
Dart__uint8_t = int
Dartintmax_t = int
Dartrd_kafka_event_type_t = int
Dartu_int32_t = int
Dartuintmax_t = int
FILE = __sFILE
fpos_t = __darwin_off_t
intmax_t = Long
mode_t = __darwin_mode_t
off_t = __darwin_off_t
rd_kafka_acl_result_t = rd_kafka_acl_result_s
rd_kafka_AclBinding_t = rd_kafka_AclBinding_s
@brief ACL Binding is used to create access control lists.
rd_kafka_AclBindingFilter_t = rd_kafka_AclBinding_t
@brief ACL Binding filter is used to filter access control lists.
rd_kafka_AdminOptions_t = rd_kafka_AdminOptions_s
@brief AdminOptions provides a generic mechanism for setting optional parameters for the Admin API requests.
rd_kafka_AlterConfigs_result_t = rd_kafka_event_t
! AlterConfigs result type
rd_kafka_AlterConsumerGroupOffsets_result_t = rd_kafka_event_t
! AlterConsumerGroupOffsets result type
rd_kafka_AlterConsumerGroupOffsets_t = rd_kafka_AlterConsumerGroupOffsets_s
! Represents consumer group committed offsets to be altered.
rd_kafka_AlterUserScramCredentials_result_response_t = rd_kafka_AlterUserScramCredentials_result_response_s
@brief Result of a single user SCRAM alteration.
rd_kafka_AlterUserScramCredentials_result_t = rd_kafka_event_t
! AlterUserScramCredentials result type
rd_kafka_conf_t = rd_kafka_conf_s
rd_kafka_ConfigEntry_t = rd_kafka_ConfigEntry_s
! Apache Kafka configuration entry.
rd_kafka_ConfigResource_t = rd_kafka_ConfigResource_s
! Apache Kafka configuration resource.
rd_kafka_consumer_group_metadata_t = rd_kafka_consumer_group_metadata_s
rd_kafka_ConsumerGroupDescription_t = rd_kafka_ConsumerGroupDescription_s
@brief DescribeConsumerGroups result type.
rd_kafka_ConsumerGroupListing_t = rd_kafka_ConsumerGroupListing_s
! ListConsumerGroups result for a single group
rd_kafka_CreateAcls_result_t = rd_kafka_event_t
! CreateAcls result type
rd_kafka_CreatePartitions_result_t = rd_kafka_event_t
! CreatePartitions result type
rd_kafka_CreateTopics_result_t = rd_kafka_event_t
! CreateTopics result type
rd_kafka_DeleteAcls_result_response_t = rd_kafka_DeleteAcls_result_response_s
DeleteAcls - delete access control lists.
rd_kafka_DeleteAcls_result_t = rd_kafka_event_t
! DeleteAcls result type
rd_kafka_DeleteConsumerGroupOffsets_result_t = rd_kafka_event_t
! DeleteConsumerGroupOffsets result type
rd_kafka_DeleteConsumerGroupOffsets_t = rd_kafka_DeleteConsumerGroupOffsets_s
! Represents consumer group committed offsets to be deleted.
rd_kafka_DeleteGroup_t = rd_kafka_DeleteGroup_s
! Represents a group to be deleted.
rd_kafka_DeleteGroups_result_t = rd_kafka_event_t
! DeleteGroups result type
rd_kafka_DeleteRecords_result_t = rd_kafka_event_t
! DeleteRecords result type
rd_kafka_DeleteRecords_t = rd_kafka_DeleteRecords_s
! Represents records to be deleted
rd_kafka_DeleteTopic_t = rd_kafka_DeleteTopic_s
! Represents a topic to be deleted.
rd_kafka_DeleteTopics_result_t = rd_kafka_event_t
! DeleteTopics result type
rd_kafka_DescribeAcls_result_t = rd_kafka_event_t
! DescribeAcls result type
rd_kafka_DescribeCluster_result_t = rd_kafka_event_t
! DescribeCluster result type
rd_kafka_DescribeConfigs_result_t = rd_kafka_event_t
! CreateTopics result type
rd_kafka_DescribeConsumerGroups_result_t = rd_kafka_event_t
! DescribeConsumerGroups result type
rd_kafka_DescribeTopics_result_t = rd_kafka_event_t
! DescribeTopics result type
rd_kafka_DescribeUserScramCredentials_result_t = rd_kafka_event_t
! DescribeUserScramCredentials result type
rd_kafka_ElectLeaders_result_t = rd_kafka_event_t
! ElectLeaders result type
rd_kafka_ElectLeaders_t = rd_kafka_ElectLeaders_s
@brief Represents elect leaders request.
rd_kafka_error_t = rd_kafka_error_s
rd_kafka_event_t = rd_kafka_op_s
rd_kafka_event_type_t = Int
@brief Event types
rd_kafka_group_result_t = rd_kafka_group_result_s
rd_kafka_headers_t = rd_kafka_headers_s
rd_kafka_IncrementalAlterConfigs_result_t = rd_kafka_event_t
! IncrementalAlterConfigs result type
rd_kafka_interceptor_f_on_acknowledgement_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Pointer<rd_kafka_message_t> rkmessage, Pointer<Void> ic_opaque)>
@brief on_acknowledgement() is called to inform interceptors that a message was succesfully delivered or permanently failed delivery. The interceptor chain is called from internal librdkafka background threads, or rd_kafka_produce*() if the partitioner failed.
rd_kafka_interceptor_f_on_broker_state_change_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Int32 broker_id, Pointer<Char> secproto, Pointer<Char> name, Int port, Pointer<Char> state, Pointer<Void> ic_opaque)>
@brief on_broker_state_change() is called just after a broker has been created or its state has been changed.
rd_kafka_interceptor_f_on_commit_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Pointer<rd_kafka_topic_partition_list_t> offsets, Int32 err, Pointer<Void> ic_opaque)>
@brief on_commit() is called on completed or failed offset commit. It is called from internal librdkafka threads.
rd_kafka_interceptor_f_on_conf_destroy_t = NativeFunction<Int32 Function(Pointer<Void> ic_opaque)>
@brief on_conf_destroy() is called from rd_kafka_*_conf_destroy() in the order the interceptors were added.
rd_kafka_interceptor_f_on_conf_dup_t = NativeFunction<Int32 Function(Pointer<rd_kafka_conf_t> new_conf, Pointer<rd_kafka_conf_t> old_conf, Size filter_cnt, Pointer<Pointer<Char>> filter, Pointer<Void> ic_opaque)>
@brief on_conf_dup() is called from rd_kafka_conf_dup() in the order the interceptors were added and is used to let an interceptor re-register its conf interecptors with a new opaque value. The on_conf_dup() method is called prior to the configuration from \p old_conf being copied to \p new_conf.
rd_kafka_interceptor_f_on_conf_set_t = NativeFunction<Int32 Function(Pointer<rd_kafka_conf_t> conf, Pointer<Char> name, Pointer<Char> val, Pointer<Char> errstr, Size errstr_size, Pointer<Void> ic_opaque)>
@brief on_conf_set() is called from rd_kafka_*_conf_set() in the order the interceptors were added.
rd_kafka_interceptor_f_on_consume_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Pointer<rd_kafka_message_t> rkmessage, Pointer<Void> ic_opaque)>
@brief on_consume() is called just prior to passing the message to the application in rd_kafka_consumer_poll(), rd_kafka_consume*(), the event interface, etc.
rd_kafka_interceptor_f_on_destroy_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Pointer<Void> ic_opaque)>
@brief on_destroy() is called from rd_kafka_destroy() or (rd_kafka_new() if rd_kafka_new() fails during initialization).
rd_kafka_interceptor_f_on_new_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Pointer<rd_kafka_conf_t> conf, Pointer<Void> ic_opaque, Pointer<Char> errstr, Size errstr_size)>
@brief on_new() is called from rd_kafka_new() prior toreturning the newly created client instance to the application.
rd_kafka_interceptor_f_on_request_sent_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Int sockfd, Pointer<Char> brokername, Int32 brokerid, Int16 ApiKey, Int16 ApiVersion, Int32 CorrId, Size size, Pointer<Void> ic_opaque)>
@brief on_request_sent() is called when a request has been fully written to a broker TCP connections socket.
rd_kafka_interceptor_f_on_response_received_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Int sockfd, Pointer<Char> brokername, Int32 brokerid, Int16 ApiKey, Int16 ApiVersion, Int32 CorrId, Size size, Int64 rtt, Int32 err, Pointer<Void> ic_opaque)>
@brief on_response_received() is called when a protocol response has been fully received from a broker TCP connection socket but before the response payload is parsed.
rd_kafka_interceptor_f_on_send_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Pointer<rd_kafka_message_t> rkmessage, Pointer<Void> ic_opaque)>
@brief on_send() is called from rd_kafka_produce*() (et.al) prior to the partitioner being called.
rd_kafka_interceptor_f_on_thread_exit_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Int32 thread_type, Pointer<Char> thread_name, Pointer<Void> ic_opaque)>
@brief on_thread_exit() is called just prior to a librdkafka-managed thread exiting from the exiting thread itself.
rd_kafka_interceptor_f_on_thread_start_t = NativeFunction<Int32 Function(Pointer<rd_kafka_t> rk, Int32 thread_type, Pointer<Char> thread_name, Pointer<Void> ic_opaque)>
@brief on_thread_start() is called from a newly created librdkafka-managed thread.
rd_kafka_ListConsumerGroupOffsets_result_t = rd_kafka_event_t
! ListConsumerGroupOffsets result type
rd_kafka_ListConsumerGroupOffsets_t = rd_kafka_ListConsumerGroupOffsets_s
! Represents consumer group committed offsets to be listed.
rd_kafka_ListConsumerGroups_result_t = rd_kafka_event_t
! ListConsumerGroups result type
rd_kafka_ListOffsets_result_t = rd_kafka_event_t
! ListOffsets result type
rd_kafka_ListOffsetsResultInfo_t = rd_kafka_ListOffsetsResultInfo_s
@brief Information returned from a ListOffsets call for a specific rd_kafka_topic_partition_t.
rd_kafka_MemberAssignment_t = rd_kafka_MemberAssignment_s
@brief Member assignment included in MemberDescription.
rd_kafka_MemberDescription_t = rd_kafka_MemberDescription_s
@brief Member description included in ConsumerGroupDescription.
rd_kafka_message_t = rd_kafka_message_s
@brief A Kafka message as returned by the \c rd_kafka_consume*() family of functions as well as provided to the Producer \c dr_msg_cb().
rd_kafka_NewPartitions_t = rd_kafka_NewPartitions_s
! Defines a new partition to be created.
rd_kafka_NewTopic_t = rd_kafka_NewTopic_s
! Defines a new topic to be created.
rd_kafka_Node_t = rd_kafka_Node_s
@brief Node (broker) information.
rd_kafka_queue_t = rd_kafka_queue_s
rd_kafka_ScramCredentialInfo_t = rd_kafka_ScramCredentialInfo_s
@brief Scram credential info. Mechanism and iterations for a SASL/SCRAM credential associated with a user.
rd_kafka_t = rd_kafka_s
rd_kafka_topic_conf_t = rd_kafka_topic_conf_s
rd_kafka_topic_partition_list_t = rd_kafka_topic_partition_list_s
@brief A growable list of Topic+Partitions.
rd_kafka_topic_partition_result_t = rd_kafka_topic_partition_result_s
rd_kafka_topic_partition_t = rd_kafka_topic_partition_s
@brief Generic place holder for a specific Topic+Partition.
rd_kafka_topic_result_t = rd_kafka_topic_result_s
rd_kafka_topic_t = rd_kafka_topic_s
rd_kafka_TopicCollection_t = rd_kafka_TopicCollection_s
@brief Represents a collection of topics, to be passed to DescribeTopics.
rd_kafka_TopicDescription_t = rd_kafka_TopicDescription_s
@brief DescribeTopics result type.
rd_kafka_TopicPartitionInfo_t = rd_kafka_TopicPartitionInfo_s
@brief TopicPartition represents a partition in the DescribeTopics result.
rd_kafka_UserScramCredentialAlteration_t = rd_kafka_UserScramCredentialAlteration_s
@brief A request to alter a user's SASL/SCRAM credentials.
rd_kafka_UserScramCredentialsDescription_t = rd_kafka_UserScramCredentialsDescription_s
@brief Representation of all SASL/SCRAM credentials associated with a user that can be retrieved, or an error indicating why credentials could not be retrieved.
rd_kafka_Uuid_t = rd_kafka_Uuid_s
rd_kafka_vu_t = rd_kafka_vu_s
@brief VTYPE + argument container for use with rd_kafka_produce_va()
sa_endpoints_t = sa_endpoints
sa_family_t = __uint8_t
sae_associd_t = __uint32_t
sae_connid_t = __uint32_t
socklen_t = __darwin_socklen_t
ssize_t = __darwin_ssize_t
u_int32_t = UnsignedInt
uintmax_t = UnsignedLong
va_list = __darwin_va_list