Overview

Traits

• \RdKafka\FFI\Methods 🤍

Classes

• \RdKafka 💛
• \RdKafka\Admin\AlterConfigsOptions 💚
• \RdKafka\Admin\Client 💛
• \RdKafka\Admin\ConfigEntry 💚
• \RdKafka\Admin\ConfigResource 💚
• \RdKafka\Admin\ConfigResourceResult 💚
• \RdKafka\Admin\CreatePartitionsOptions 💚
• \RdKafka\Admin\CreateTopicsOptions 💚
• \RdKafka\Admin\DeleteConsumerGroupOffsets ❤️
• \RdKafka\Admin\DeleteConsumerGroupOffsetsOptions ❤️
• \RdKafka\Admin\DeleteGroup ❤️
• \RdKafka\Admin\DeleteGroupsOptions ❤️
• \RdKafka\Admin\DeleteRecords 🧡
• \RdKafka\Admin\DeleteRecordsOptions 💚
• \RdKafka\Admin\DeleteTopic 🧡
• \RdKafka\Admin\DeleteTopicsOptions 💚
• \RdKafka\Admin\DescribeConfigsOptions 💚
• \RdKafka\Admin\GroupResult ❤️
• \RdKafka\Admin\NewPartitions 💚
• \RdKafka\Admin\NewTopic 💛
• \RdKafka\Admin\Options 💛
• \RdKafka\Admin\TopicResult 💚
• \RdKafka\Conf 💚
• \RdKafka\Consumer 💚
• \RdKafka\ConsumerTopic 💛
• \RdKafka\Event 💛
• \RdKafka\Exception 💚
• \RdKafka\FFI\CallbackProxy 💚
• \RdKafka\FFI\ConsumeCallbackProxy 💚
• \RdKafka\FFI\DrMsgCallbackProxy 💚
• \RdKafka\FFI\ErrorCallbackProxy 💚
• \RdKafka\FFI\Library 💛
• \RdKafka\FFI\LogCallbackProxy 💚
• \RdKafka\FFI\NativePartitionerCallbackProxy 💚
• \RdKafka\FFI\OffsetCommitCallbackProxy 💚
• \RdKafka\FFI\OpaqueMap 💚
• \RdKafka\FFI\PartitionerCallbackProxy 💚
• \RdKafka\FFI\RebalanceCallbackProxy 💚
• \RdKafka\FFI\StatsCallbackProxy 💚
• \RdKafka\KafkaConsumer 💛
• \RdKafka\KafkaConsumerTopic 💛
• \RdKafka\KafkaErrorException 💚
• \RdKafka\Message 💛
• \RdKafka\Metadata 💚
• \RdKafka\Metadata\Broker 💚
• \RdKafka\Metadata\Collection 💚
• \RdKafka\Metadata\Partition 💛
• \RdKafka\Metadata\Topic 💚
• \RdKafka\Producer 💛
• \RdKafka\ProducerTopic 💛
• \RdKafka\Queue 💛
• \RdKafka\Test\ApiKey ❤️
• \RdKafka\Test\MockCluster 🧡
• \RdKafka\Topic 💛
• \RdKafka\TopicConf 💛
• \RdKafka\TopicPartition 💚
• \RdKafka\TopicPartitionList 💚

Functions

• \rd_kafka_err2name()
• \rd_kafka_err2str()
• \rd_kafka_errno()
• \rd_kafka_errno2err()
• \rd_kafka_offset_tail()
• \rd_kafka_thread_cnt()
• \rd_kafka_version()

Constants

• \RD_KAFKA_ACL_OPERATION_ALL
• \RD_KAFKA_ACL_OPERATION_ALTER
• \RD_KAFKA_ACL_OPERATION_ALTER_CONFIGS
• \RD_KAFKA_ACL_OPERATION_ANY
• \RD_KAFKA_ACL_OPERATION_CLUSTER_ACTION
• \RD_KAFKA_ACL_OPERATION_CREATE
• \RD_KAFKA_ACL_OPERATION_DELETE
• \RD_KAFKA_ACL_OPERATION_DESCRIBE
• \RD_KAFKA_ACL_OPERATION_DESCRIBE_CONFIGS
• \RD_KAFKA_ACL_OPERATION_IDEMPOTENT_WRITE
• \RD_KAFKA_ACL_OPERATION_READ
• \RD_KAFKA_ACL_OPERATION_UNKNOWN
• \RD_KAFKA_ACL_OPERATION_WRITE
• \RD_KAFKA_ACL_OPERATION__CNT
• \RD_KAFKA_ACL_PERMISSION_TYPE_ALLOW
• \RD_KAFKA_ACL_PERMISSION_TYPE_ANY
• \RD_KAFKA_ACL_PERMISSION_TYPE_DENY
• \RD_KAFKA_ACL_PERMISSION_TYPE_UNKNOWN
• \RD_KAFKA_ACL_PERMISSION_TYPE__CNT
• \RD_KAFKA_ADMIN_OP_ALTERCONFIGS
• \RD_KAFKA_ADMIN_OP_ALTERCONSUMERGROUPOFFSETS
• \RD_KAFKA_ADMIN_OP_ALTERUSERSCRAMCREDENTIALS
• \RD_KAFKA_ADMIN_OP_ANY
• \RD_KAFKA_ADMIN_OP_CREATEACLS
• \RD_KAFKA_ADMIN_OP_CREATEPARTITIONS
• \RD_KAFKA_ADMIN_OP_CREATETOPICS
• \RD_KAFKA_ADMIN_OP_DELETEACLS
• \RD_KAFKA_ADMIN_OP_DELETECONSUMERGROUPOFFSETS
• \RD_KAFKA_ADMIN_OP_DELETEGROUPS
• \RD_KAFKA_ADMIN_OP_DELETERECORDS
• \RD_KAFKA_ADMIN_OP_DELETETOPICS
• \RD_KAFKA_ADMIN_OP_DESCRIBEACLS
• \RD_KAFKA_ADMIN_OP_DESCRIBECLUSTER
• \RD_KAFKA_ADMIN_OP_DESCRIBECONFIGS
• \RD_KAFKA_ADMIN_OP_DESCRIBECONSUMERGROUPS
• \RD_KAFKA_ADMIN_OP_DESCRIBETOPICS
• \RD_KAFKA_ADMIN_OP_DESCRIBEUSERSCRAMCREDENTIALS
• \RD_KAFKA_ADMIN_OP_ELECTLEADERS
• \RD_KAFKA_ADMIN_OP_INCREMENTALALTERCONFIGS
• \RD_KAFKA_ADMIN_OP_LISTCONSUMERGROUPOFFSETS
• \RD_KAFKA_ADMIN_OP_LISTCONSUMERGROUPS
• \RD_KAFKA_ADMIN_OP_LISTOFFSETS
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ADMIN_OP__CNT
• \RD_KAFKA_ALTER_CONFIG_OP_TYPE_APPEND
• \RD_KAFKA_ALTER_CONFIG_OP_TYPE_DELETE
• \RD_KAFKA_ALTER_CONFIG_OP_TYPE_SET
• \RD_KAFKA_ALTER_CONFIG_OP_TYPE_SUBTRACT
• \RD_KAFKA_ALTER_CONFIG_OP_TYPE__CNT
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CDEF
• \RD_KAFKA_CERT_CA
• \RD_KAFKA_CERT_ENC_DER
• \RD_KAFKA_CERT_ENC_PEM
• \RD_KAFKA_CERT_ENC_PKCS12
• \RD_KAFKA_CERT_ENC__CNT
• \RD_KAFKA_CERT_PRIVATE_KEY
• \RD_KAFKA_CERT_PUBLIC_KEY
• \RD_KAFKA_CERT__CNT
• \RD_KAFKA_CONFIG_SOURCE_DEFAULT_CONFIG
• \RD_KAFKA_CONFIG_SOURCE_DYNAMIC_BROKER_CONFIG
• \RD_KAFKA_CONFIG_SOURCE_DYNAMIC_DEFAULT_BROKER_CONFIG
• \RD_KAFKA_CONFIG_SOURCE_DYNAMIC_TOPIC_CONFIG
• \RD_KAFKA_CONFIG_SOURCE_STATIC_BROKER_CONFIG
• \RD_KAFKA_CONFIG_SOURCE_UNKNOWN_CONFIG
• \RD_KAFKA_CONFIG_SOURCE__CNT
• \RD_KAFKA_CONF_INVALID
• \RD_KAFKA_CONF_OK
• \RD_KAFKA_CONF_UNKNOWN
• \RD_KAFKA_CONSUMER
• \RD_KAFKA_CONSUMER_GROUP_STATE_COMPLETING_REBALANCE
• \RD_KAFKA_CONSUMER_GROUP_STATE_DEAD
• \RD_KAFKA_CONSUMER_GROUP_STATE_EMPTY
• \RD_KAFKA_CONSUMER_GROUP_STATE_PREPARING_REBALANCE
• \RD_KAFKA_CONSUMER_GROUP_STATE_STABLE
• \RD_KAFKA_CONSUMER_GROUP_STATE_UNKNOWN
• \RD_KAFKA_CONSUMER_GROUP_STATE__CNT
• \RD_KAFKA_CONSUMER_GROUP_TYPE_CLASSIC
• \RD_KAFKA_CONSUMER_GROUP_TYPE_CONSUMER
• \RD_KAFKA_CONSUMER_GROUP_TYPE_UNKNOWN
• \RD_KAFKA_CONSUMER_GROUP_TYPE__CNT
• \RD_KAFKA_DESTROY_F_NO_CONSUMER_CLOSE
• \RD_KAFKA_ELECTION_TYPE_PREFERRED
• \RD_KAFKA_ELECTION_TYPE_UNCLEAN
• \RD_KAFKA_EVENT_ALTERCONFIGS_RESULT
• \RD_KAFKA_EVENT_ALTERCONSUMERGROUPOFFSETS_RESULT
• \RD_KAFKA_EVENT_ALTERUSERSCRAMCREDENTIALS_RESULT
• \RD_KAFKA_EVENT_BACKGROUND
• \RD_KAFKA_EVENT_CREATEACLS_RESULT
• \RD_KAFKA_EVENT_CREATEPARTITIONS_RESULT
• \RD_KAFKA_EVENT_CREATETOPICS_RESULT
• \RD_KAFKA_EVENT_DELETEACLS_RESULT
• \RD_KAFKA_EVENT_DELETECONSUMERGROUPOFFSETS_RESULT
• \RD_KAFKA_EVENT_DELETEGROUPS_RESULT
• \RD_KAFKA_EVENT_DELETERECORDS_RESULT
• \RD_KAFKA_EVENT_DELETETOPICS_RESULT
• \RD_KAFKA_EVENT_DESCRIBEACLS_RESULT
• \RD_KAFKA_EVENT_DESCRIBECLUSTER_RESULT
• \RD_KAFKA_EVENT_DESCRIBECONFIGS_RESULT
• \RD_KAFKA_EVENT_DESCRIBECONSUMERGROUPS_RESULT
• \RD_KAFKA_EVENT_DESCRIBETOPICS_RESULT
• \RD_KAFKA_EVENT_DESCRIBEUSERSCRAMCREDENTIALS_RESULT
• \RD_KAFKA_EVENT_DR
• \RD_KAFKA_EVENT_ELECTLEADERS_RESULT
• \RD_KAFKA_EVENT_ERROR
• \RD_KAFKA_EVENT_FETCH
• \RD_KAFKA_EVENT_INCREMENTALALTERCONFIGS_RESULT
• \RD_KAFKA_EVENT_LISTCONSUMERGROUPOFFSETS_RESULT
• \RD_KAFKA_EVENT_LISTCONSUMERGROUPS_RESULT
• \RD_KAFKA_EVENT_LISTOFFSETS_RESULT
• \RD_KAFKA_EVENT_LOG
• \RD_KAFKA_EVENT_NONE
• \RD_KAFKA_EVENT_OAUTHBEARER_TOKEN_REFRESH
• \RD_KAFKA_EVENT_OFFSET_COMMIT
• \RD_KAFKA_EVENT_REBALANCE
• \RD_KAFKA_EVENT_STATS
• \RD_KAFKA_ISOLATION_LEVEL_READ_COMMITTED
• \RD_KAFKA_ISOLATION_LEVEL_READ_UNCOMMITTED
• \RD_KAFKA_LOG_PRINT
• \RD_KAFKA_LOG_SYSLOG
• \RD_KAFKA_LOG_SYSLOG_PRINT
• \RD_KAFKA_MSG_F_BLOCK
• \RD_KAFKA_MSG_F_COPY
• \RD_KAFKA_MSG_F_FREE
• \RD_KAFKA_MSG_F_PARTITION
• \RD_KAFKA_MSG_PARTITIONER_CONSISTENT
• \RD_KAFKA_MSG_PARTITIONER_CONSISTENT_RANDOM
• \RD_KAFKA_MSG_PARTITIONER_FNV1A
• \RD_KAFKA_MSG_PARTITIONER_FNV1A_RANDOM
• \RD_KAFKA_MSG_PARTITIONER_MURMUR2
• \RD_KAFKA_MSG_PARTITIONER_MURMUR2_RANDOM
• \RD_KAFKA_MSG_PARTITIONER_RANDOM
• \RD_KAFKA_MSG_STATUS_NOT_PERSISTED
• \RD_KAFKA_MSG_STATUS_PERSISTED
• \RD_KAFKA_MSG_STATUS_POSSIBLY_PERSISTED
• \RD_KAFKA_OFFSET_BEGINNING
• \RD_KAFKA_OFFSET_END
• \RD_KAFKA_OFFSET_INVALID
• \RD_KAFKA_OFFSET_SPEC_EARLIEST
• \RD_KAFKA_OFFSET_SPEC_LATEST
• \RD_KAFKA_OFFSET_SPEC_MAX_TIMESTAMP
• \RD_KAFKA_OFFSET_STORED
• \RD_KAFKA_OFFSET_TAIL_BASE
• \RD_KAFKA_PARTITION_UA
• \RD_KAFKA_PRODUCER
• \RD_KAFKA_PURGE_F_INFLIGHT
• \RD_KAFKA_PURGE_F_NON_BLOCKING
• \RD_KAFKA_PURGE_F_QUEUE
• \RD_KAFKA_RESOURCE_ANY
• \RD_KAFKA_RESOURCE_BROKER
• \RD_KAFKA_RESOURCE_GROUP
• \RD_KAFKA_RESOURCE_PATTERN_ANY
• \RD_KAFKA_RESOURCE_PATTERN_LITERAL
• \RD_KAFKA_RESOURCE_PATTERN_MATCH
• \RD_KAFKA_RESOURCE_PATTERN_PREFIXED
• \RD_KAFKA_RESOURCE_PATTERN_TYPE__CNT
• \RD_KAFKA_RESOURCE_PATTERN_UNKNOWN
• \RD_KAFKA_RESOURCE_TOPIC
• \RD_KAFKA_RESOURCE_TRANSACTIONAL_ID
• \RD_KAFKA_RESOURCE_UNKNOWN
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESOURCE__CNT
• \RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE
• \RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED
• \RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS
• \RD_KAFKA_RESP_ERR_COORDINATOR_LOAD_IN_PROGRESS
• \RD_KAFKA_RESP_ERR_COORDINATOR_NOT_AVAILABLE
• \RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTHORIZATION_FAILED
• \RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTH_DISABLED
• \RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_EXPIRED
• \RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_NOT_FOUND
• \RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_OWNER_MISMATCH
• \RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_REQUEST_NOT_ALLOWED
• \RD_KAFKA_RESP_ERR_DUPLICATE_RESOURCE
• \RD_KAFKA_RESP_ERR_DUPLICATE_SEQUENCE_NUMBER
• \RD_KAFKA_RESP_ERR_ELECTION_NOT_NEEDED
• \RD_KAFKA_RESP_ERR_ELIGIBLE_LEADERS_NOT_AVAILABLE
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_END_ALL
• \RD_KAFKA_RESP_ERR_FEATURE_UPDATE_FAILED
• \RD_KAFKA_RESP_ERR_FENCED_INSTANCE_ID
• \RD_KAFKA_RESP_ERR_FENCED_LEADER_EPOCH
• \RD_KAFKA_RESP_ERR_FENCED_MEMBER_EPOCH
• \RD_KAFKA_RESP_ERR_FETCH_SESSION_ID_NOT_FOUND
• \RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED
• \RD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLE
• \RD_KAFKA_RESP_ERR_GROUP_ID_NOT_FOUND
• \RD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESS
• \RD_KAFKA_RESP_ERR_GROUP_MAX_SIZE_REACHED
• \RD_KAFKA_RESP_ERR_GROUP_SUBSCRIBED_TO_TOPIC
• \RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION
• \RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE
• \RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL
• \RD_KAFKA_RESP_ERR_INCONSISTENT_VOTER_SET
• \RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE
• \RD_KAFKA_RESP_ERR_INVALID_CONFIG
• \RD_KAFKA_RESP_ERR_INVALID_FETCH_SESSION_EPOCH
• \RD_KAFKA_RESP_ERR_INVALID_GROUP_ID
• \RD_KAFKA_RESP_ERR_INVALID_MSG
• \RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE
• \RD_KAFKA_RESP_ERR_INVALID_PARTITIONS
• \RD_KAFKA_RESP_ERR_INVALID_PRINCIPAL_TYPE
• \RD_KAFKA_RESP_ERR_INVALID_PRODUCER_EPOCH
• \RD_KAFKA_RESP_ERR_INVALID_PRODUCER_ID_MAPPING
• \RD_KAFKA_RESP_ERR_INVALID_RECORD
• \RD_KAFKA_RESP_ERR_INVALID_REPLICATION_FACTOR
• \RD_KAFKA_RESP_ERR_INVALID_REPLICA_ASSIGNMENT
• \RD_KAFKA_RESP_ERR_INVALID_REQUEST
• \RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS
• \RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT
• \RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP
• \RD_KAFKA_RESP_ERR_INVALID_TRANSACTION_TIMEOUT
• \RD_KAFKA_RESP_ERR_INVALID_TXN_STATE
• \RD_KAFKA_RESP_ERR_INVALID_UPDATE_VERSION
• \RD_KAFKA_RESP_ERR_KAFKA_STORAGE_ERROR
• \RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE
• \RD_KAFKA_RESP_ERR_LISTENER_NOT_FOUND
• \RD_KAFKA_RESP_ERR_LOG_DIR_NOT_FOUND
• \RD_KAFKA_RESP_ERR_MEMBER_ID_REQUIRED
• \RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE
• \RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION
• \RD_KAFKA_RESP_ERR_NON_EMPTY_GROUP
• \RD_KAFKA_RESP_ERR_NOT_CONTROLLER
• \RD_KAFKA_RESP_ERR_NOT_COORDINATOR
• \RD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUP
• \RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS
• \RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND
• \RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION
• \RD_KAFKA_RESP_ERR_NO_ERROR
• \RD_KAFKA_RESP_ERR_NO_REASSIGNMENT_IN_PROGRESS
• \RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE
• \RD_KAFKA_RESP_ERR_OFFSET_NOT_AVAILABLE
• \RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE
• \RD_KAFKA_RESP_ERR_OPERATION_NOT_ATTEMPTED
• \RD_KAFKA_RESP_ERR_OUT_OF_ORDER_SEQUENCE_NUMBER
• \RD_KAFKA_RESP_ERR_POLICY_VIOLATION
• \RD_KAFKA_RESP_ERR_PREFERRED_LEADER_NOT_AVAILABLE
• \RD_KAFKA_RESP_ERR_PRINCIPAL_DESERIALIZATION_FAILURE
• \RD_KAFKA_RESP_ERR_PRODUCER_FENCED
• \RD_KAFKA_RESP_ERR_REASSIGNMENT_IN_PROGRESS
• \RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS
• \RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE
• \RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE
• \RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT
• \RD_KAFKA_RESP_ERR_RESOURCE_NOT_FOUND
• \RD_KAFKA_RESP_ERR_SASL_AUTHENTICATION_FAILED
• \RD_KAFKA_RESP_ERR_SECURITY_DISABLED
• \RD_KAFKA_RESP_ERR_STALE_BROKER_EPOCH
• \RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH
• \RD_KAFKA_RESP_ERR_STALE_MEMBER_EPOCH
• \RD_KAFKA_RESP_ERR_TELEMETRY_TOO_LARGE
• \RD_KAFKA_RESP_ERR_THROTTLING_QUOTA_EXCEEDED
• \RD_KAFKA_RESP_ERR_TOPIC_ALREADY_EXISTS
• \RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED
• \RD_KAFKA_RESP_ERR_TOPIC_DELETION_DISABLED
• \RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION
• \RD_KAFKA_RESP_ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED
• \RD_KAFKA_RESP_ERR_TRANSACTION_COORDINATOR_FENCED
• \RD_KAFKA_RESP_ERR_UNACCEPTABLE_CREDENTIAL
• \RD_KAFKA_RESP_ERR_UNKNOWN
• \RD_KAFKA_RESP_ERR_UNKNOWN_LEADER_EPOCH
• \RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID
• \RD_KAFKA_RESP_ERR_UNKNOWN_PRODUCER_ID
• \RD_KAFKA_RESP_ERR_UNKNOWN_SUBSCRIPTION_ID
• \RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_ID
• \RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART
• \RD_KAFKA_RESP_ERR_UNRELEASED_INSTANCE_ID
• \RD_KAFKA_RESP_ERR_UNSTABLE_OFFSET_COMMIT
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_ASSIGNOR
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM
• \RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION
• \RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN
• \RD_KAFKA_RESP_ERR__APPLICATION
• \RD_KAFKA_RESP_ERR__ASSIGNMENT_LOST
• \RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS
• \RD_KAFKA_RESP_ERR__AUTHENTICATION
• \RD_KAFKA_RESP_ERR__AUTO_OFFSET_RESET
• \RD_KAFKA_RESP_ERR__BAD_COMPRESSION
• \RD_KAFKA_RESP_ERR__BAD_MSG
• \RD_KAFKA_RESP_ERR__BEGIN
• \RD_KAFKA_RESP_ERR__CONFLICT
• \RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE
• \RD_KAFKA_RESP_ERR__DESTROY
• \RD_KAFKA_RESP_ERR__END
• \RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION
• \RD_KAFKA_RESP_ERR__FAIL
• \RD_KAFKA_RESP_ERR__FATAL
• \RD_KAFKA_RESP_ERR__FENCED
• \RD_KAFKA_RESP_ERR__FS
• \RD_KAFKA_RESP_ERR__GAPLESS_GUARANTEE
• \RD_KAFKA_RESP_ERR__INCONSISTENT
• \RD_KAFKA_RESP_ERR__INTR
• \RD_KAFKA_RESP_ERR__INVALID_ARG
• \RD_KAFKA_RESP_ERR__INVALID_DIFFERENT_RECORD
• \RD_KAFKA_RESP_ERR__INVALID_TYPE
• \RD_KAFKA_RESP_ERR__IN_PROGRESS
• \RD_KAFKA_RESP_ERR__ISR_INSUFF
• \RD_KAFKA_RESP_ERR__KEY_DESERIALIZATION
• \RD_KAFKA_RESP_ERR__KEY_SERIALIZATION
• \RD_KAFKA_RESP_ERR__LOG_TRUNCATION
• \RD_KAFKA_RESP_ERR__MAX_POLL_EXCEEDED
• \RD_KAFKA_RESP_ERR__MSG_TIMED_OUT
• \RD_KAFKA_RESP_ERR__NODE_UPDATE
• \RD_KAFKA_RESP_ERR__NOENT
• \RD_KAFKA_RESP_ERR__NOOP
• \RD_KAFKA_RESP_ERR__NOT_CONFIGURED
• \RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED
• \RD_KAFKA_RESP_ERR__NO_OFFSET
• \RD_KAFKA_RESP_ERR__OUTDATED
• \RD_KAFKA_RESP_ERR__PARTIAL
• \RD_KAFKA_RESP_ERR__PARTITION_EOF
• \RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS
• \RD_KAFKA_RESP_ERR__PURGE_INFLIGHT
• \RD_KAFKA_RESP_ERR__PURGE_QUEUE
• \RD_KAFKA_RESP_ERR__QUEUE_FULL
• \RD_KAFKA_RESP_ERR__READ_ONLY
• \RD_KAFKA_RESP_ERR__RESOLVE
• \RD_KAFKA_RESP_ERR__RETRY
• \RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS
• \RD_KAFKA_RESP_ERR__SSL
• \RD_KAFKA_RESP_ERR__STATE
• \RD_KAFKA_RESP_ERR__TIMED_OUT
• \RD_KAFKA_RESP_ERR__TIMED_OUT_QUEUE
• \RD_KAFKA_RESP_ERR__TRANSPORT
• \RD_KAFKA_RESP_ERR__UNDERFLOW
• \RD_KAFKA_RESP_ERR__UNKNOWN_BROKER
• \RD_KAFKA_RESP_ERR__UNKNOWN_GROUP
• \RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION
• \RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL
• \RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC
• \RD_KAFKA_RESP_ERR__UNSUPPORTED_FEATURE
• \RD_KAFKA_RESP_ERR__VALUE_DESERIALIZATION
• \RD_KAFKA_RESP_ERR__VALUE_SERIALIZATION
• \RD_KAFKA_RESP_ERR__WAIT_CACHE
• \RD_KAFKA_RESP_ERR__WAIT_COORD
• \RD_KAFKA_SCRAM_MECHANISM_SHA_256
• \RD_KAFKA_SCRAM_MECHANISM_SHA_512
• \RD_KAFKA_SCRAM_MECHANISM_UNKNOWN
• \RD_KAFKA_SCRAM_MECHANISM__CNT
• \RD_KAFKA_SUPPORTED_METHODS
• \RD_KAFKA_THREAD_BACKGROUND
• \RD_KAFKA_THREAD_BROKER
• \RD_KAFKA_THREAD_MAIN
• \RD_KAFKA_TIMESTAMP_CREATE_TIME
• \RD_KAFKA_TIMESTAMP_LOG_APPEND_TIME
• \RD_KAFKA_TIMESTAMP_NOT_AVAILABLE
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VERSION
• \RD_KAFKA_VTYPE_END
• \RD_KAFKA_VTYPE_HEADER
• \RD_KAFKA_VTYPE_HEADERS
• \RD_KAFKA_VTYPE_KEY
• \RD_KAFKA_VTYPE_MSGFLAGS
• \RD_KAFKA_VTYPE_OPAQUE
• \RD_KAFKA_VTYPE_PARTITION
• \RD_KAFKA_VTYPE_RKT
• \RD_KAFKA_VTYPE_TIMESTAMP
• \RD_KAFKA_VTYPE_TOPIC
• \RD_KAFKA_VTYPE_VALUE

Test Coverage 💛

• 💛 Lines: 84.58% (1267 / 1498)
• ❤️ Classes: 44.64% (25 / 56)
• 🧡 Methods: 65.66% (195 / 297)