Namespace: RdKafka

RdKafka

Namespace for non-promifisied, callback-based Kafka client API.

Classes

AdminClient
Client
HighLevelProducer
KafkaConsumer
KafkaConsumerStream
LibrdKafkaError
OffsetSpec
Producer
ProducerStream

Members

(static, constant) AclOperationTypes :number

A list of ACL operation types.

Type:
  • number
Properties:
Name Type Description
UNKNOWN number
ANY number
ALL number
READ number
WRITE number
CREATE number
DELETE number
ALTER number
DESCRIBE number
CLUSTER_ACTION number
DESCRIBE_CONFIGS number
ALTER_CONFIGS number
IDEMPOTENT_WRITE number

(static, constant) ConsumerGroupStates :number

A list of consumer group states.

Type:
  • number
Properties:
Name Type Description
UNKNOWN number
PREPARING_REBALANCE number
COMPLETING_REBALANCE number
STABLE number
DEAD number
EMPTY number

(static, constant) IsolationLevel :number

A list of isolation levels.

Type:
  • number
Properties:
Name Type Description
READ_UNCOMMITTED number
READ_COMMITTED number

(static, constant) LibrdKafkaError.codes :number

Enum for identifying errors reported by the library

You can find this list in the C++ code at https://github.com/confluentinc/librdkafka/blob/master/src-cpp/rdkafkacpp.h#L148

Type:
  • number
Properties:
Name Type Description
ERR__BEGIN number

Begin internal error codes
ERR__BAD_MSG number

Received message is incorrect
ERR__BAD_COMPRESSION number

Bad/unknown compression
ERR__DESTROY number

Broker is going away
ERR__FAIL number

Generic failure
ERR__TRANSPORT number

Broker transport failure
ERR__CRIT_SYS_RESOURCE number

Critical system resource
ERR__RESOLVE number

Failed to resolve broker
ERR__MSG_TIMED_OUT number

Produced message timed out
ERR__PARTITION_EOF number

Reached the end of the topic+partition queue on the broker. Not really an error. This event is disabled by default, see the enable.partition.eof configuration property.
ERR__UNKNOWN_PARTITION number

Permanent: Partition does not exist in cluster.
ERR__FS number

File or filesystem error
ERR__UNKNOWN_TOPIC number

Permanent: Topic does not exist in cluster.
ERR__ALL_BROKERS_DOWN number

All broker connections are down.
ERR__INVALID_ARG number

Invalid argument, or invalid configuration
ERR__TIMED_OUT number

Operation timed out
ERR__QUEUE_FULL number

Queue is full
ERR__ISR_INSUFF number

ISR count < required.acks
ERR__NODE_UPDATE number

Broker node update
ERR__SSL number

SSL error
ERR__WAIT_COORD number

Waiting for coordinator to become available.
ERR__UNKNOWN_GROUP number

Unknown client group
ERR__IN_PROGRESS number

Operation in progress
ERR__PREV_IN_PROGRESS number

Previous operation in progress, wait for it to finish.
ERR__EXISTING_SUBSCRIPTION number

This operation would interfere with an existing subscription
ERR__ASSIGN_PARTITIONS number

Assigned partitions (rebalance_cb)
ERR__REVOKE_PARTITIONS number

Revoked partitions (rebalance_cb)
ERR__CONFLICT number

Conflicting use
ERR__STATE number

Wrong state
ERR__UNKNOWN_PROTOCOL number

Unknown protocol
ERR__NOT_IMPLEMENTED number

Not implemented
ERR__AUTHENTICATION number

Authentication failure
ERR__NO_OFFSET number

No stored offset
ERR__OUTDATED number

Outdated
ERR__TIMED_OUT_QUEUE number

Timed out in queue
ERR__UNSUPPORTED_FEATURE number

Feature not supported by broker
ERR__WAIT_CACHE number

Awaiting cache update
ERR__INTR number

Operation interrupted
ERR__KEY_SERIALIZATION number

Key serialization error
ERR__VALUE_SERIALIZATION number

Value serialization error
ERR__KEY_DESERIALIZATION number

Key deserialization error
ERR__VALUE_DESERIALIZATION number

Value deserialization error
ERR__PARTIAL number

Partial response
ERR__READ_ONLY number

Modification attempted on read-only object
ERR__NOENT number

No such entry / item not found
ERR__UNDERFLOW number

Read underflow
ERR__INVALID_TYPE number

Invalid type
ERR__RETRY number

Retry operation
ERR__PURGE_QUEUE number

Purged in queue
ERR__PURGE_INFLIGHT number

Purged in flight
ERR__FATAL number

Fatal error: see RdKafka::Handle::fatal_error()
ERR__INCONSISTENT number

Inconsistent state
ERR__GAPLESS_GUARANTEE number

Gap-less ordering would not be guaranteed if proceeding
ERR__MAX_POLL_EXCEEDED number

Maximum poll interval exceeded
ERR__UNKNOWN_BROKER number

Unknown broker
ERR__NOT_CONFIGURED number

Functionality not configured
ERR__FENCED number

Instance has been fenced
ERR__APPLICATION number

Application generated error
ERR__ASSIGNMENT_LOST number

Assignment lost
ERR__NOOP number

No operation performed
ERR__AUTO_OFFSET_RESET number

No offset to automatically reset to
ERR__LOG_TRUNCATION number

Partition log truncation detected
ERR__INVALID_DIFFERENT_RECORD number

A different record in the batch was invalid and this message failed persisting.
ERR__DESTROY_BROKER number

Broker is going away but client isn't terminating
ERR__END number

End internal error codes
ERR_UNKNOWN number

Unknown broker error
ERR_NO_ERROR number

Success
ERR_OFFSET_OUT_OF_RANGE number

Offset out of range
ERR_INVALID_MSG number

Invalid message
ERR_UNKNOWN_TOPIC_OR_PART number

Unknown topic or partition
ERR_INVALID_MSG_SIZE number

Invalid message size
ERR_LEADER_NOT_AVAILABLE number

Leader not available
ERR_NOT_LEADER_FOR_PARTITION number

Not leader for partition
ERR_REQUEST_TIMED_OUT number

Request timed out
ERR_BROKER_NOT_AVAILABLE number

Broker not available
ERR_REPLICA_NOT_AVAILABLE number

Replica not available
ERR_MSG_SIZE_TOO_LARGE number

Message size too large
ERR_STALE_CTRL_EPOCH number

StaleControllerEpochCode
ERR_OFFSET_METADATA_TOO_LARGE number

Offset metadata string too large
ERR_NETWORK_EXCEPTION number

Broker disconnected before response received
ERR_COORDINATOR_LOAD_IN_PROGRESS number

Coordinator load in progress
ERR_GROUP_LOAD_IN_PROGRESS number

Group coordinator load in progress
ERR_COORDINATOR_NOT_AVAILABLE number

Coordinator not available
ERR_GROUP_COORDINATOR_NOT_AVAILABLE number

Group coordinator not available
ERR_NOT_COORDINATOR number

Not coordinator
ERR_NOT_COORDINATOR_FOR_GROUP number

Not coordinator for group
ERR_TOPIC_EXCEPTION number

Invalid topic
ERR_RECORD_LIST_TOO_LARGE number

Message batch larger than configured server segment size
ERR_NOT_ENOUGH_REPLICAS number

Not enough in-sync replicas
ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND number

Message(s) written to insufficient number of in-sync replicas
ERR_INVALID_REQUIRED_ACKS number

Invalid required acks value
ERR_ILLEGAL_GENERATION number

Specified group generation id is not valid
ERR_INCONSISTENT_GROUP_PROTOCOL number

Inconsistent group protocol
ERR_INVALID_GROUP_ID number

Invalid group.id
ERR_UNKNOWN_MEMBER_ID number

Unknown member
ERR_INVALID_SESSION_TIMEOUT number

Invalid session timeout
ERR_REBALANCE_IN_PROGRESS number

Group rebalance in progress
ERR_INVALID_COMMIT_OFFSET_SIZE number

Commit offset data size is not valid
ERR_TOPIC_AUTHORIZATION_FAILED number

Topic authorization failed
ERR_GROUP_AUTHORIZATION_FAILED number

Group authorization failed
ERR_CLUSTER_AUTHORIZATION_FAILED number

Cluster authorization failed
ERR_INVALID_TIMESTAMP number

Invalid timestamp
ERR_UNSUPPORTED_SASL_MECHANISM number

Unsupported SASL mechanism
ERR_ILLEGAL_SASL_STATE number

Illegal SASL state
ERR_UNSUPPORTED_VERSION number

Unuspported version
ERR_TOPIC_ALREADY_EXISTS number

Topic already exists
ERR_INVALID_PARTITIONS number

Invalid number of partitions
ERR_INVALID_REPLICATION_FACTOR number

Invalid replication factor
ERR_INVALID_REPLICA_ASSIGNMENT number

Invalid replica assignment
ERR_INVALID_CONFIG number

Invalid config
ERR_NOT_CONTROLLER number

Not controller for cluster
ERR_INVALID_REQUEST number

Invalid request
ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT number

Message format on broker does not support request
ERR_POLICY_VIOLATION number

Policy violation
ERR_OUT_OF_ORDER_SEQUENCE_NUMBER number

Broker received an out of order sequence number
ERR_DUPLICATE_SEQUENCE_NUMBER number

Broker received a duplicate sequence number
ERR_INVALID_PRODUCER_EPOCH number

Producer attempted an operation with an old epoch
ERR_INVALID_TXN_STATE number

Producer attempted a transactional operation in an invalid state
ERR_INVALID_PRODUCER_ID_MAPPING number

Producer attempted to use a producer id which is not currently assigned to its transactional id
ERR_INVALID_TRANSACTION_TIMEOUT number

Transaction timeout is larger than the maximum value allowed by the broker's max.transaction.timeout.ms
ERR_CONCURRENT_TRANSACTIONS number

Producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing
ERR_TRANSACTION_COORDINATOR_FENCED number

Indicates that the transaction coordinator sending a WriteTxnMarker is no longer the current coordinator for a given producer
ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED number

Transactional Id authorization failed
ERR_SECURITY_DISABLED number

Security features are disabled
ERR_OPERATION_NOT_ATTEMPTED number

Operation not attempted
ERR_KAFKA_STORAGE_ERROR number

Disk error when trying to access log file on the disk
ERR_LOG_DIR_NOT_FOUND number

The user-specified log directory is not found in the broker config
ERR_SASL_AUTHENTICATION_FAILED number

SASL Authentication failed
ERR_UNKNOWN_PRODUCER_ID number

Unknown Producer Id
ERR_REASSIGNMENT_IN_PROGRESS number

Partition reassignment is in progress
ERR_DELEGATION_TOKEN_AUTH_DISABLED number

Delegation Token feature is not enabled
ERR_DELEGATION_TOKEN_NOT_FOUND number

Delegation Token is not found on server
ERR_DELEGATION_TOKEN_OWNER_MISMATCH number

Specified Principal is not valid Owner/Renewer
ERR_DELEGATION_TOKEN_REQUEST_NOT_ALLOWED number

Delegation Token requests are not allowed on this connection
ERR_DELEGATION_TOKEN_AUTHORIZATION_FAILED number

Delegation Token authorization failed
ERR_DELEGATION_TOKEN_EXPIRED number

Delegation Token is expired
ERR_INVALID_PRINCIPAL_TYPE number

Supplied principalType is not supported
ERR_NON_EMPTY_GROUP number

The group is not empty
ERR_GROUP_ID_NOT_FOUND number

The group id does not exist
ERR_FETCH_SESSION_ID_NOT_FOUND number

The fetch session ID was not found
ERR_INVALID_FETCH_SESSION_EPOCH number

The fetch session epoch is invalid
ERR_LISTENER_NOT_FOUND number

No matching listener
ERR_TOPIC_DELETION_DISABLED number

Topic deletion is disabled
ERR_FENCED_LEADER_EPOCH number

Leader epoch is older than broker epoch
ERR_UNKNOWN_LEADER_EPOCH number

Leader epoch is newer than broker epoch
ERR_UNSUPPORTED_COMPRESSION_TYPE number

Unsupported compression type
ERR_STALE_BROKER_EPOCH number

Broker epoch has changed
ERR_OFFSET_NOT_AVAILABLE number

Leader high watermark is not caught up
ERR_MEMBER_ID_REQUIRED number

Group member needs a valid member ID
ERR_PREFERRED_LEADER_NOT_AVAILABLE number

Preferred leader was not available
ERR_GROUP_MAX_SIZE_REACHED number

Consumer group has reached maximum size
ERR_FENCED_INSTANCE_ID number

Static consumer fenced by other consumer with same group.instance.id.
ERR_ELIGIBLE_LEADERS_NOT_AVAILABLE number

Eligible partition leaders are not available
ERR_ELECTION_NOT_NEEDED number

Leader election not needed for topic partition
ERR_NO_REASSIGNMENT_IN_PROGRESS number

No partition reassignment is in progress
ERR_GROUP_SUBSCRIBED_TO_TOPIC number

Deleting offsets of a topic while the consumer group is subscribed to it
ERR_INVALID_RECORD number

Broker failed to validate record
ERR_UNSTABLE_OFFSET_COMMIT number

There are unstable offsets that need to be cleared
ERR_THROTTLING_QUOTA_EXCEEDED number

Throttling quota has been exceeded
ERR_PRODUCER_FENCED number

There is a newer producer with the same transactionalId which fences the current one
ERR_RESOURCE_NOT_FOUND number

Request illegally referred to resource that does not exist
ERR_DUPLICATE_RESOURCE number

Request illegally referred to the same resource twice
ERR_UNACCEPTABLE_CREDENTIAL number

Requested credential would not meet criteria for acceptability
ERR_INCONSISTENT_VOTER_SET number

Indicates that the either the sender or recipient of a voter-only request is not one of the expected voters
ERR_INVALID_UPDATE_VERSION number

Invalid update version
ERR_FEATURE_UPDATE_FAILED number

Unable to update finalized features due to server error
ERR_PRINCIPAL_DESERIALIZATION_FAILURE number

Request principal deserialization failed during forwarding
ERR_UNKNOWN_TOPIC_ID number

Unknown Topic Id
ERR_FENCED_MEMBER_EPOCH number

The member epoch is fenced by the group coordinator
ERR_UNRELEASED_INSTANCE_ID number

The instance ID is still used by another member in the consumer group
ERR_UNSUPPORTED_ASSIGNOR number

The assignor or its version range is not supported by the consumer group
ERR_STALE_MEMBER_EPOCH number

The member epoch is stale
ERR_UNKNOWN_SUBSCRIPTION_ID number

Client sent a push telemetry request with an invalid or outdated subscription ID.
ERR_TELEMETRY_TOO_LARGE number

Client sent a push telemetry request larger than the maximum size the broker will accept.
ERR_REBOOTSTRAP_REQUIRED number

Client metadata is stale, client should rebootstrap to obtain new metadata.