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 |
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. |