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) ConsumerGroupTypes :number
A list of consumer group types.
Type:
- number
- See:
- RdKafka.ConsumerGroupTypes
(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