Namespace for promifisied, async Kafka client API.
Classes
- Admin
- Consumer
- Kafka
- KafkaJSAggregateError
- KafkaJSConnectionError
- KafkaJSCreateTopicError
- KafkaJSDeleteGroupsError
- KafkaJSDeleteTopicRecordsError
- KafkaJSError
- KafkaJSGroupCoordinatorNotFound
- KafkaJSNoBrokerAvailableError
- KafkaJSNotImplemented
- KafkaJSOffsetOutOfRange
- KafkaJSPartialMessageError
- KafkaJSProtocolError
- KafkaJSRequestTimeoutError
- KafkaJSSASLAuthenticationError
- KafkaJSTimeout
- Producer
Members
(static, readonly) AclOperationTypes :number
A list of ACL operation types.
Type:
- number
(static, constant) CompressionTypes :string
A list of supported compression types.
Type:
- string
Properties:
| Name | Type | Description |
|---|---|---|
None |
string | |
GZIP |
string | |
SNAPPY |
string | |
LZ4 |
string | |
ZSTD |
string |
(static, readonly) ConsumerGroupStates :number
A list of consumer group states.
Type:
- number
(static, readonly) IsolationLevel :number
A list of isolation levels.
Type:
- number
(static, constant) PartitionAssigners :string
A list of supported partition assignor types.
Type:
- string
Properties:
| Name | Type | Description |
|---|---|---|
roundRobin |
string | |
range |
string | |
cooperativeSticky |
string |
Methods
(static) isKafkaJSError(e) → {boolean}
Parameters:
| Name | Type | Description |
|---|---|---|
e |
any |
Returns:
Returns whether the error is a KafkaJSError.
- Type
- boolean
(static) isRebalancing(e) → {boolean}
Parameters:
| Name | Type | Description |
|---|---|---|
e |
KafkaJS.KafkaJSError |
Returns:
Returns whether the error is a rebalancing error.
- Type
- boolean