@qualithm/kafka-client - v0.1.6
GitHub
Preparing search index...
index
Module index
Native Apache Kafka client for JavaScript and TypeScript runtimes.
Classes
BinaryReader
BinaryWriter
ConnectionPool
Kafka
KafkaAdmin
KafkaConfigError
KafkaConnection
KafkaConnectionError
KafkaConsumer
KafkaError
KafkaProducer
KafkaProtocolError
KafkaTimeoutError
SchemaRegistry
SchemaRegistryError
TelemetryReporter
Type Aliases
Acks
AclCreation
AclCreationResult
AclDescription
AclOperation
AclPermissionType
AclResourcePatternType
AclResourceType
AddOffsetsToTxnRequest
AddOffsetsToTxnResponse
AddPartitionsToTxnPartitionResult
AddPartitionsToTxnRequest
AddPartitionsToTxnResponse
AddPartitionsToTxnTopic
AddPartitionsToTxnTopicResult
AdminOptions
AdminRetryConfig
AlterClientQuotasEntity
AlterClientQuotasEntry
AlterClientQuotasEntryResponse
AlterClientQuotasOp
AlterClientQuotasRequest
AlterClientQuotasResponse
AlterClientQuotasResponseEntity
AlterConfigOpValue
AlterConfigOpValue
AlterConfigsEntry
AlterConfigsRequest
AlterConfigsResource
AlterConfigsResourceResponse
AlterConfigsResponse
AlterPartitionReassignmentsRequest
AlterPartitionReassignmentsResponse
AlterReplicaLogDirsEntry
AlterReplicaLogDirsPartitionResponse
AlterReplicaLogDirsRequest
AlterReplicaLogDirsResponse
AlterReplicaLogDirsTopic
AlterReplicaLogDirsTopicResponse
AlterUserScramCredentialsRequest
AlterUserScramCredentialsResponse
AlterUserScramCredentialsResultEntry
ApiKey
ApiVersionEntry
ApiVersionRange
ApiVersionsRequest
ApiVersionsResponse
AssignedPartition
AsyncDeserializer
AsyncSerde
AsyncSerializer
AvroCodec
AvroSchema
AvroSerdeOptions
BatchConfig
BrokerAddress
BrokerInfo
CompressionCodec
CompressionProvider
ConfigResourceType
ConfigSynonym
ConnectionOptions
ConnectionPoolOptions
ConsumerGroupDescribeAssignment
ConsumerGroupDescribeGroup
ConsumerGroupDescribeMember
ConsumerGroupDescribeRequest
ConsumerGroupDescribeResponse
ConsumerGroupDescribeTopicPartition
ConsumerGroupHeartbeatAssignment
ConsumerGroupHeartbeatRequest
ConsumerGroupHeartbeatRequestTopicPartition
ConsumerGroupHeartbeatResponse
ConsumerGroupHeartbeatResponseTopicPartition
ConsumerOptions
ConsumerRecord
ConsumerRetryConfig
Coordinator
CoordinatorType
CreatableRenewers
CreateAclsRequest
CreateAclsResponse
CreateDelegationTokenRequest
CreateDelegationTokenResponse
CreatePartitionsAssignment
CreatePartitionsRequest
CreatePartitionsResponse
CreatePartitionsTopicRequest
CreatePartitionsTopicResponse
CreateTopicRequest
CreateTopicsConfigEntry
CreateTopicsReplicaAssignment
CreateTopicsRequest
CreateTopicsResponse
CreateTopicsResponseConfigEntry
CreateTopicsTopicResponse
CredentialInfo
DecodeError
DecodeErrorCode
DecodeFailure
DecodeResult
DecodeSuccess
DeleteAclsFilter
DeleteAclsFilterResult
DeleteAclsMatchingAcl
DeleteAclsRequest
DeleteAclsResponse
DeleteGroupsRequest
DeleteGroupsResponse
DeleteGroupsResult
DeleteRecordsPartitionRequest
DeleteRecordsPartitionResponse
DeleteRecordsRequest
DeleteRecordsResponse
DeleteRecordsTopicRequest
DeleteRecordsTopicResponse
DeleteTopicsRequest
DeleteTopicsResponse
DeleteTopicState
DeleteTopicsTopicResponse
DescribeAclsRequest
DescribeAclsResource
DescribeAclsResponse
DescribeClientQuotasComponent
DescribeClientQuotasEntry
DescribeClientQuotasRequest
DescribeClientQuotasResponse
DescribeClusterBroker
DescribeClusterRequest
DescribeClusterResponse
DescribeConfigsEntry
DescribeConfigsRequest
DescribeConfigsResource
DescribeConfigsResourceResponse
DescribeConfigsResponse
DescribedDelegationToken
DescribeDelegationTokenOwner
DescribeDelegationTokenRequest
DescribeDelegationTokenResponse
DescribedTokenRenewer
DescribeGroupsGroup
DescribeGroupsMember
DescribeGroupsRequest
DescribeGroupsResponse
DescribeLogDirsPartition
DescribeLogDirsRequest
DescribeLogDirsResponse
DescribeLogDirsResult
DescribeLogDirsTopic
DescribeLogDirsTopicResponse
DescribeProducersPartitionResponse
DescribeProducersRequest
DescribeProducersResponse
DescribeProducersTopicRequest
DescribeProducersTopicResponse
DescribeQuorumPartitionRequest
DescribeQuorumPartitionResponse
DescribeQuorumRequest
DescribeQuorumResponse
DescribeQuorumTopicRequest
DescribeQuorumTopicResponse
DescribeTopicPartitionsPartitionResponse
DescribeTopicPartitionsRequest
DescribeTopicPartitionsResponse
DescribeTopicPartitionsTopicRequest
DescribeTopicPartitionsTopicResponse
DescribeTransactionsRequest
DescribeTransactionsResponse
DescribeUserScramCredentialsRequest
DescribeUserScramCredentialsResponse
DescribeUserScramCredentialsResult
Deserializer
ElectionType
ElectLeadersPartitionRequest
ElectLeadersPartitionResponse
ElectLeadersRequest
ElectLeadersResponse
ElectLeadersTopicRequest
ElectLeadersTopicResponse
EndTxnRequest
EndTxnResponse
ExpireDelegationTokenRequest
ExpireDelegationTokenResponse
FeatureUpdateKey
FetchAbortedTransaction
FetchIsolationLevel
FetchPartitionRequest
FetchPartitionResponse
FetchRequest
FetchResponse
FetchTopicRequest
FetchTopicResponse
FindCoordinatorRequest
FindCoordinatorResponse
FlexibleVersionThreshold
ForgottenTopic
GetTelemetrySubscriptionsRequest
GetTelemetrySubscriptionsResponse
GroupProtocol
HeartbeatRequest
HeartbeatResponse
IncrementalAlterConfigsEntry
IncrementalAlterConfigsRequest
IncrementalAlterConfigsResource
IncrementalAlterConfigsResourceResponse
IncrementalAlterConfigsResponse
InitProducerIdRequest
InitProducerIdResponse
IsolationLevel
JoinGroupMember
JoinGroupProtocol
JoinGroupRequest
JoinGroupResponse
KafkaAdminOptions
KafkaConfig
KafkaConsumerOptions
KafkaOptions
KafkaProducerOptions
KafkaSocket
KafkaState
LeaveGroupMemberRequest
LeaveGroupMemberResponse
LeaveGroupRequest
LeaveGroupResponse
ListedTransaction
ListGroupsGroup
ListGroupsRequest
ListGroupsResponse
ListOffsetsPartitionRequest
ListOffsetsPartitionResponse
ListOffsetsRequest
ListOffsetsResponse
ListOffsetsTopicRequest
ListOffsetsTopicResponse
ListPartitionReassignmentsRequest
ListPartitionReassignmentsResponse
ListReassignmentsTopic
ListTransactionsRequest
ListTransactionsResponse
Lz4Codec
MemberAssignment
MemberSubscription
Message
MessageHeader
MetadataBroker
MetadataPartition
MetadataRequest
MetadataRequestTopic
MetadataResponse
MetadataTopic
MetricsCollector
Offset
OffsetCommitPartitionRequest
OffsetCommitPartitionResponse
OffsetCommitRequest
OffsetCommitResponse
OffsetCommitTopicRequest
OffsetCommitTopicResponse
OffsetFetchPartitionResponse
OffsetFetchRequest
OffsetFetchResponse
OffsetFetchTopicRequest
OffsetFetchTopicResponse
OffsetForLeaderEpochPartitionRequest
OffsetForLeaderEpochPartitionResponse
OffsetForLeaderEpochRequest
OffsetForLeaderEpochResponse
OffsetForLeaderEpochTopicRequest
OffsetForLeaderEpochTopicResponse
OffsetResetStrategy
OffsetTimestamp
OngoingPartitionReassignment
OngoingTopicReassignment
PartitionAssignor
Partitioner
ProducePartitionData
ProducePartitionResponse
ProduceRecordError
ProduceRequest
ProduceResponse
ProduceResult
ProducerOptions
ProducerState
ProduceTopicData
ProduceTopicResponse
ProtobufCodec
ProtobufSchema
ProtobufSerdeOptions
PushTelemetryRequest
PushTelemetryResponse
QuorumNode
QuorumNodeListener
QuotaEntity
QuotaMatchType
QuotaValue
ReassignablePartition
ReassignablePartitionResponse
ReassignableTopic
ReassignableTopicResponse
RebalanceListener
ReconnectStrategy
Record
RecordBatch
RecordBatchAttributes
RecordBatchOptions
RegisteredSchema
RenewDelegationTokenRequest
RenewDelegationTokenResponse
ReplicaState
RequestHeader
RequestHeaderVersion
ResponseHeader
ResponseHeaderVersion
RetryConfig
SaslAuthenticateRequest
SaslAuthenticateResponse
SaslAuthenticator
SaslConfig
SaslHandshakeRequest
SaslHandshakeResponse
SaslMechanism
SchemaRegistryConfig
SchemaType
ScramAlgorithm
ScramCredentialDeletion
ScramCredentialUpsertion
ScramMechanism
Serde
Serializer
SnappyCodec
SocketConnectOptions
SocketFactory
SubjectNameStrategy
SyncGroupAssignment
SyncGroupRequest
SyncGroupResponse
TaggedField
TelemetryConfig
TelemetrySubscription
TimestampType
TlsConfig
TopicInfo
TopicPartition
TopicPartitionOffset
TopicPartitionsCursor
TransactionState
TransactionTopicPartition
TxnOffsetCommitPartitionRequest
TxnOffsetCommitPartitionResponse
TxnOffsetCommitRequest
TxnOffsetCommitResponse
TxnOffsetCommitTopicRequest
TxnOffsetCommitTopicResponse
UpdatableFeatureResult
UpdateFeaturesRequest
UpdateFeaturesResponse
UserScramCredentialsUser
ZstdCodec
Variables
Acks
AclOperation
AclPermissionType
AclResourcePatternType
AclResourceType
ApiKey
CLIENT_API_VERSIONS
CompressionCodec
ConfigResourceType
CoordinatorType
deflateProvider
FetchIsolationLevel
FLEXIBLE_VERSION_THRESHOLDS
GroupProtocol
gzipProvider
IsolationLevel
OffsetResetStrategy
OffsetTimestamp
QuotaMatchType
rangeAssignor
RECORD_BATCH_HEADER_OVERHEAD
RECORD_BATCH_MAGIC
RECORD_BATCH_METADATA_SIZE
roundRobinAssignor
ScramMechanism
stringSerializer
TimestampType
topicNameStrategy
WIRE_FORMAT_HEADER_SIZE
WIRE_FORMAT_MAGIC
Functions
apiVersionsToMap
buildAddOffsetsToTxnRequest
buildAddPartitionsToTxnRequest
buildAlterClientQuotasRequest
buildAlterConfigsRequest
buildAlterPartitionReassignmentsRequest
buildAlterReplicaLogDirsRequest
buildAlterUserScramCredentialsRequest
buildApiVersionsRequest
buildConsumerGroupDescribeRequest
buildConsumerGroupHeartbeatRequest
buildCreateAclsRequest
buildCreateDelegationTokenRequest
buildCreatePartitionsRequest
buildCreateTopicsRequest
buildDeleteAclsRequest
buildDeleteGroupsRequest
buildDeleteRecordsRequest
buildDeleteTopicsRequest
buildDescribeAclsRequest
buildDescribeClientQuotasRequest
buildDescribeClusterRequest
buildDescribeConfigsRequest
buildDescribeDelegationTokenRequest
buildDescribeGroupsRequest
buildDescribeLogDirsRequest
buildDescribeProducersRequest
buildDescribeQuorumRequest
buildDescribeTopicPartitionsRequest
buildDescribeTransactionsRequest
buildDescribeUserScramCredentialsRequest
buildElectLeadersRequest
buildEndTxnRequest
buildExpireDelegationTokenRequest
buildFetchRequest
buildFindCoordinatorRequest
buildGetTelemetrySubscriptionsRequest
buildHeartbeatRequest
buildIncrementalAlterConfigsRequest
buildInitProducerIdRequest
buildJoinGroupRequest
buildLeaveGroupRequest
buildListGroupsRequest
buildListOffsetsRequest
buildListPartitionReassignmentsRequest
buildListTransactionsRequest
buildMetadataRequest
buildOffsetCommitRequest
buildOffsetFetchRequest
buildOffsetForLeaderEpochRequest
buildProduceRequest
buildPushTelemetryRequest
buildRecordBatch
buildRenewDelegationTokenRequest
buildSaslAuthenticateRequest
buildSaslHandshakeRequest
buildSyncGroupRequest
buildTxnOffsetCommitRequest
buildUpdateFeaturesRequest
crc32c
createAdmin
createAvroSerde
createBunSocketFactory
createConsumer
createCooperativeStickyAssignor
createDenoSocketFactory
createKafka
createLz4Provider
createNodeSocketFactory
createPlainAuthenticator
createProducer
createProtobufSerde
createRecord
createSaslAuthenticator
createScramAuthenticator
createSnappyProvider
createZstdProvider
decodeAddOffsetsToTxnResponse
decodeAddPartitionsToTxnResponse
decodeAlterClientQuotasResponse
decodeAlterConfigsResponse
decodeAlterPartitionReassignmentsResponse
decodeAlterReplicaLogDirsResponse
decodeAlterUserScramCredentialsResponse
decodeApiVersionsResponse
decodeAttributes
decodeConsumerGroupDescribeResponse
decodeConsumerGroupHeartbeatResponse
decodeCreateAclsResponse
decodeCreateDelegationTokenResponse
decodeCreatePartitionsResponse
decodeCreateTopicsResponse
decodeDeleteAclsResponse
decodeDeleteGroupsResponse
decodeDeleteRecordsResponse
decodeDeleteTopicsResponse
decodeDescribeAclsResponse
decodeDescribeClientQuotasResponse
decodeDescribeClusterResponse
decodeDescribeConfigsResponse
decodeDescribeDelegationTokenResponse
decodeDescribeGroupsResponse
decodeDescribeLogDirsResponse
decodeDescribeProducersResponse
decodeDescribeQuorumResponse
decodeDescribeTopicPartitionsResponse
decodeDescribeTransactionsResponse
decodeDescribeUserScramCredentialsResponse
decodeElectLeadersResponse
decodeEndTxnResponse
decodeExpireDelegationTokenResponse
decodeFailure
decodeFetchResponse
decodeFindCoordinatorResponse
decodeGetTelemetrySubscriptionsResponse
decodeHeartbeatResponse
decodeIncrementalAlterConfigsResponse
decodeInitProducerIdResponse
decodeJoinGroupResponse
decodeLeaveGroupResponse
decodeListGroupsResponse
decodeListOffsetsResponse
decodeListPartitionReassignmentsResponse
decodeListTransactionsResponse
decodeMetadataResponse
decodeOffsetCommitResponse
decodeOffsetFetchResponse
decodeOffsetForLeaderEpochResponse
decodeProduceResponse
decodePushTelemetryResponse
decodeRecordBatch
decodeRenewDelegationTokenResponse
decodeResponseHeader
decodeSaslAuthenticateResponse
decodeSaslHandshakeResponse
decodeSuccess
decodeSyncGroupResponse
decodeTxnOffsetCommitResponse
decodeUpdateFeaturesResponse
decodeWireFormatHeader
defaultPartitioner
discoverBrokers
encodeAddOffsetsToTxnRequest
encodeAddPartitionsToTxnRequest
encodeAlterClientQuotasRequest
encodeAlterConfigsRequest
encodeAlterPartitionReassignmentsRequest
encodeAlterReplicaLogDirsRequest
encodeAlterUserScramCredentialsRequest
encodeApiVersionsRequest
encodeAttributes
encodeConsumerGroupDescribeRequest
encodeConsumerGroupHeartbeatRequest
encodeCreateAclsRequest
encodeCreateDelegationTokenRequest
encodeCreatePartitionsRequest
encodeCreateTopicsRequest
encodeDeleteAclsRequest
encodeDeleteGroupsRequest
encodeDeleteRecordsRequest
encodeDeleteTopicsRequest
encodeDescribeAclsRequest
encodeDescribeClientQuotasRequest
encodeDescribeClusterRequest
encodeDescribeConfigsRequest
encodeDescribeDelegationTokenRequest
encodeDescribeGroupsRequest
encodeDescribeLogDirsRequest
encodeDescribeProducersRequest
encodeDescribeQuorumRequest
encodeDescribeTopicPartitionsRequest
encodeDescribeTransactionsRequest
encodeDescribeUserScramCredentialsRequest
encodeElectLeadersRequest
encodeEndTxnRequest
encodeExpireDelegationTokenRequest
encodeFetchRequest
encodeFindCoordinatorRequest
encodeGetTelemetrySubscriptionsRequest
encodeHeartbeatRequest
encodeIncrementalAlterConfigsRequest
encodeInitProducerIdRequest
encodeJoinGroupRequest
encodeLeaveGroupRequest
encodeListGroupsRequest
encodeListOffsetsRequest
encodeListPartitionReassignmentsRequest
encodeListTransactionsRequest
encodeMetadataRequest
encodeOffsetCommitRequest
encodeOffsetFetchRequest
encodeOffsetForLeaderEpochRequest
encodeProduceRequest
encodePushTelemetryRequest
encodeRecordBatch
encodeRenewDelegationTokenRequest
encodeRequestHeader
encodeSaslAuthenticateRequest
encodeSaslHandshakeRequest
encodeSyncGroupRequest
encodeTxnOffsetCommitRequest
encodeUpdateFeaturesRequest
encodeWireFormatHeader
frameRequest
hasCompressionProvider
isFlexibleVersion
jsonSerializer
negotiateVersion
parseBrokerAddress
readResponseFrame
recordNameStrategy
registerCompressionProvider
requestHeaderVersion
responseHeaderVersion
roundRobinPartitioner
topicRecordNameStrategy
References
AlterConfigOp
 →Â
AlterConfigOpValue
Settings
Member Visibility
Inherited
Theme
OS
Light
Dark
On This Page
Classes
Binary
Reader
Binary
Writer
Connection
Pool
Kafka
Kafka
Admin
Kafka
Config
Error
Kafka
Connection
Kafka
Connection
Error
Kafka
Consumer
Kafka
Error
Kafka
Producer
Kafka
Protocol
Error
Kafka
Timeout
Error
Schema
Registry
Schema
Registry
Error
Telemetry
Reporter
Type Aliases
Acks
Acl
Creation
Acl
Creation
Result
Acl
Description
Acl
Operation
Acl
Permission
Type
Acl
Resource
Pattern
Type
Acl
Resource
Type
Add
Offsets
To
Txn
Request
Add
Offsets
To
Txn
Response
Add
Partitions
To
Txn
Partition
Result
Add
Partitions
To
Txn
Request
Add
Partitions
To
Txn
Response
Add
Partitions
To
Txn
Topic
Add
Partitions
To
Txn
Topic
Result
Admin
Options
Admin
Retry
Config
Alter
Client
Quotas
Entity
Alter
Client
Quotas
Entry
Alter
Client
Quotas
Entry
Response
Alter
Client
Quotas
Op
Alter
Client
Quotas
Request
Alter
Client
Quotas
Response
Alter
Client
Quotas
Response
Entity
Alter
Config
Op
Value
Alter
Config
Op
Value
Alter
Configs
Entry
Alter
Configs
Request
Alter
Configs
Resource
Alter
Configs
Resource
Response
Alter
Configs
Response
Alter
Partition
Reassignments
Request
Alter
Partition
Reassignments
Response
Alter
Replica
Log
Dirs
Entry
Alter
Replica
Log
Dirs
Partition
Response
Alter
Replica
Log
Dirs
Request
Alter
Replica
Log
Dirs
Response
Alter
Replica
Log
Dirs
Topic
Alter
Replica
Log
Dirs
Topic
Response
Alter
User
Scram
Credentials
Request
Alter
User
Scram
Credentials
Response
Alter
User
Scram
Credentials
Result
Entry
Api
Key
Api
Version
Entry
Api
Version
Range
Api
Versions
Request
Api
Versions
Response
Assigned
Partition
Async
Deserializer
Async
Serde
Async
Serializer
Avro
Codec
Avro
Schema
Avro
Serde
Options
Batch
Config
Broker
Address
Broker
Info
Compression
Codec
Compression
Provider
Config
Resource
Type
Config
Synonym
Connection
Options
Connection
Pool
Options
Consumer
Group
Describe
Assignment
Consumer
Group
Describe
Group
Consumer
Group
Describe
Member
Consumer
Group
Describe
Request
Consumer
Group
Describe
Response
Consumer
Group
Describe
Topic
Partition
Consumer
Group
Heartbeat
Assignment
Consumer
Group
Heartbeat
Request
Consumer
Group
Heartbeat
Request
Topic
Partition
Consumer
Group
Heartbeat
Response
Consumer
Group
Heartbeat
Response
Topic
Partition
Consumer
Options
Consumer
Record
Consumer
Retry
Config
Coordinator
Coordinator
Type
Creatable
Renewers
Create
Acls
Request
Create
Acls
Response
Create
Delegation
Token
Request
Create
Delegation
Token
Response
Create
Partitions
Assignment
Create
Partitions
Request
Create
Partitions
Response
Create
Partitions
Topic
Request
Create
Partitions
Topic
Response
Create
Topic
Request
Create
Topics
Config
Entry
Create
Topics
Replica
Assignment
Create
Topics
Request
Create
Topics
Response
Create
Topics
Response
Config
Entry
Create
Topics
Topic
Response
Credential
Info
Decode
Error
Decode
Error
Code
Decode
Failure
Decode
Result
Decode
Success
Delete
Acls
Filter
Delete
Acls
Filter
Result
Delete
Acls
Matching
Acl
Delete
Acls
Request
Delete
Acls
Response
Delete
Groups
Request
Delete
Groups
Response
Delete
Groups
Result
Delete
Records
Partition
Request
Delete
Records
Partition
Response
Delete
Records
Request
Delete
Records
Response
Delete
Records
Topic
Request
Delete
Records
Topic
Response
Delete
Topics
Request
Delete
Topics
Response
Delete
Topic
State
Delete
Topics
Topic
Response
Describe
Acls
Request
Describe
Acls
Resource
Describe
Acls
Response
Describe
Client
Quotas
Component
Describe
Client
Quotas
Entry
Describe
Client
Quotas
Request
Describe
Client
Quotas
Response
Describe
Cluster
Broker
Describe
Cluster
Request
Describe
Cluster
Response
Describe
Configs
Entry
Describe
Configs
Request
Describe
Configs
Resource
Describe
Configs
Resource
Response
Describe
Configs
Response
Described
Delegation
Token
Describe
Delegation
Token
Owner
Describe
Delegation
Token
Request
Describe
Delegation
Token
Response
Described
Token
Renewer
Describe
Groups
Group
Describe
Groups
Member
Describe
Groups
Request
Describe
Groups
Response
Describe
Log
Dirs
Partition
Describe
Log
Dirs
Request
Describe
Log
Dirs
Response
Describe
Log
Dirs
Result
Describe
Log
Dirs
Topic
Describe
Log
Dirs
Topic
Response
Describe
Producers
Partition
Response
Describe
Producers
Request
Describe
Producers
Response
Describe
Producers
Topic
Request
Describe
Producers
Topic
Response
Describe
Quorum
Partition
Request
Describe
Quorum
Partition
Response
Describe
Quorum
Request
Describe
Quorum
Response
Describe
Quorum
Topic
Request
Describe
Quorum
Topic
Response
Describe
Topic
Partitions
Partition
Response
Describe
Topic
Partitions
Request
Describe
Topic
Partitions
Response
Describe
Topic
Partitions
Topic
Request
Describe
Topic
Partitions
Topic
Response
Describe
Transactions
Request
Describe
Transactions
Response
Describe
User
Scram
Credentials
Request
Describe
User
Scram
Credentials
Response
Describe
User
Scram
Credentials
Result
Deserializer
Election
Type
Elect
Leaders
Partition
Request
Elect
Leaders
Partition
Response
Elect
Leaders
Request
Elect
Leaders
Response
Elect
Leaders
Topic
Request
Elect
Leaders
Topic
Response
End
Txn
Request
End
Txn
Response
Expire
Delegation
Token
Request
Expire
Delegation
Token
Response
Feature
Update
Key
Fetch
Aborted
Transaction
Fetch
Isolation
Level
Fetch
Partition
Request
Fetch
Partition
Response
Fetch
Request
Fetch
Response
Fetch
Topic
Request
Fetch
Topic
Response
Find
Coordinator
Request
Find
Coordinator
Response
Flexible
Version
Threshold
Forgotten
Topic
Get
Telemetry
Subscriptions
Request
Get
Telemetry
Subscriptions
Response
Group
Protocol
Heartbeat
Request
Heartbeat
Response
Incremental
Alter
Configs
Entry
Incremental
Alter
Configs
Request
Incremental
Alter
Configs
Resource
Incremental
Alter
Configs
Resource
Response
Incremental
Alter
Configs
Response
Init
Producer
Id
Request
Init
Producer
Id
Response
Isolation
Level
Join
Group
Member
Join
Group
Protocol
Join
Group
Request
Join
Group
Response
Kafka
Admin
Options
Kafka
Config
Kafka
Consumer
Options
Kafka
Options
Kafka
Producer
Options
Kafka
Socket
Kafka
State
Leave
Group
Member
Request
Leave
Group
Member
Response
Leave
Group
Request
Leave
Group
Response
Listed
Transaction
List
Groups
Group
List
Groups
Request
List
Groups
Response
List
Offsets
Partition
Request
List
Offsets
Partition
Response
List
Offsets
Request
List
Offsets
Response
List
Offsets
Topic
Request
List
Offsets
Topic
Response
List
Partition
Reassignments
Request
List
Partition
Reassignments
Response
List
Reassignments
Topic
List
Transactions
Request
List
Transactions
Response
Lz4
Codec
Member
Assignment
Member
Subscription
Message
Message
Header
Metadata
Broker
Metadata
Partition
Metadata
Request
Metadata
Request
Topic
Metadata
Response
Metadata
Topic
Metrics
Collector
Offset
Offset
Commit
Partition
Request
Offset
Commit
Partition
Response
Offset
Commit
Request
Offset
Commit
Response
Offset
Commit
Topic
Request
Offset
Commit
Topic
Response
Offset
Fetch
Partition
Response
Offset
Fetch
Request
Offset
Fetch
Response
Offset
Fetch
Topic
Request
Offset
Fetch
Topic
Response
Offset
For
Leader
Epoch
Partition
Request
Offset
For
Leader
Epoch
Partition
Response
Offset
For
Leader
Epoch
Request
Offset
For
Leader
Epoch
Response
Offset
For
Leader
Epoch
Topic
Request
Offset
For
Leader
Epoch
Topic
Response
Offset
Reset
Strategy
Offset
Timestamp
Ongoing
Partition
Reassignment
Ongoing
Topic
Reassignment
Partition
Assignor
Partitioner
Produce
Partition
Data
Produce
Partition
Response
Produce
Record
Error
Produce
Request
Produce
Response
Produce
Result
Producer
Options
Producer
State
Produce
Topic
Data
Produce
Topic
Response
Protobuf
Codec
Protobuf
Schema
Protobuf
Serde
Options
Push
Telemetry
Request
Push
Telemetry
Response
Quorum
Node
Quorum
Node
Listener
Quota
Entity
Quota
Match
Type
Quota
Value
Reassignable
Partition
Reassignable
Partition
Response
Reassignable
Topic
Reassignable
Topic
Response
Rebalance
Listener
Reconnect
Strategy
Record
Record
Batch
Record
Batch
Attributes
Record
Batch
Options
Registered
Schema
Renew
Delegation
Token
Request
Renew
Delegation
Token
Response
Replica
State
Request
Header
Request
Header
Version
Response
Header
Response
Header
Version
Retry
Config
Sasl
Authenticate
Request
Sasl
Authenticate
Response
Sasl
Authenticator
Sasl
Config
Sasl
Handshake
Request
Sasl
Handshake
Response
Sasl
Mechanism
Schema
Registry
Config
Schema
Type
Scram
Algorithm
Scram
Credential
Deletion
Scram
Credential
Upsertion
Scram
Mechanism
Serde
Serializer
Snappy
Codec
Socket
Connect
Options
Socket
Factory
Subject
Name
Strategy
Sync
Group
Assignment
Sync
Group
Request
Sync
Group
Response
Tagged
Field
Telemetry
Config
Telemetry
Subscription
Timestamp
Type
Tls
Config
Topic
Info
Topic
Partition
Topic
Partition
Offset
Topic
Partitions
Cursor
Transaction
State
Transaction
Topic
Partition
Txn
Offset
Commit
Partition
Request
Txn
Offset
Commit
Partition
Response
Txn
Offset
Commit
Request
Txn
Offset
Commit
Response
Txn
Offset
Commit
Topic
Request
Txn
Offset
Commit
Topic
Response
Updatable
Feature
Result
Update
Features
Request
Update
Features
Response
User
Scram
Credentials
User
Zstd
Codec
Variables
Acks
Acl
Operation
Acl
Permission
Type
Acl
Resource
Pattern
Type
Acl
Resource
Type
Api
Key
CLIENT_
API_
VERSIONS
Compression
Codec
Config
Resource
Type
Coordinator
Type
deflate
Provider
Fetch
Isolation
Level
FLEXIBLE_
VERSION_
THRESHOLDS
Group
Protocol
gzip
Provider
Isolation
Level
Offset
Reset
Strategy
Offset
Timestamp
Quota
Match
Type
range
Assignor
RECORD_
BATCH_
HEADER_
OVERHEAD
RECORD_
BATCH_
MAGIC
RECORD_
BATCH_
METADATA_
SIZE
round
Robin
Assignor
Scram
Mechanism
string
Serializer
Timestamp
Type
topic
Name
Strategy
WIRE_
FORMAT_
HEADER_
SIZE
WIRE_
FORMAT_
MAGIC
Functions
api
Versions
To
Map
build
Add
Offsets
To
Txn
Request
build
Add
Partitions
To
Txn
Request
build
Alter
Client
Quotas
Request
build
Alter
Configs
Request
build
Alter
Partition
Reassignments
Request
build
Alter
Replica
Log
Dirs
Request
build
Alter
User
Scram
Credentials
Request
build
Api
Versions
Request
build
Consumer
Group
Describe
Request
build
Consumer
Group
Heartbeat
Request
build
Create
Acls
Request
build
Create
Delegation
Token
Request
build
Create
Partitions
Request
build
Create
Topics
Request
build
Delete
Acls
Request
build
Delete
Groups
Request
build
Delete
Records
Request
build
Delete
Topics
Request
build
Describe
Acls
Request
build
Describe
Client
Quotas
Request
build
Describe
Cluster
Request
build
Describe
Configs
Request
build
Describe
Delegation
Token
Request
build
Describe
Groups
Request
build
Describe
Log
Dirs
Request
build
Describe
Producers
Request
build
Describe
Quorum
Request
build
Describe
Topic
Partitions
Request
build
Describe
Transactions
Request
build
Describe
User
Scram
Credentials
Request
build
Elect
Leaders
Request
build
End
Txn
Request
build
Expire
Delegation
Token
Request
build
Fetch
Request
build
Find
Coordinator
Request
build
Get
Telemetry
Subscriptions
Request
build
Heartbeat
Request
build
Incremental
Alter
Configs
Request
build
Init
Producer
Id
Request
build
Join
Group
Request
build
Leave
Group
Request
build
List
Groups
Request
build
List
Offsets
Request
build
List
Partition
Reassignments
Request
build
List
Transactions
Request
build
Metadata
Request
build
Offset
Commit
Request
build
Offset
Fetch
Request
build
Offset
For
Leader
Epoch
Request
build
Produce
Request
build
Push
Telemetry
Request
build
Record
Batch
build
Renew
Delegation
Token
Request
build
Sasl
Authenticate
Request
build
Sasl
Handshake
Request
build
Sync
Group
Request
build
Txn
Offset
Commit
Request
build
Update
Features
Request
crc32c
create
Admin
create
Avro
Serde
create
Bun
Socket
Factory
create
Consumer
create
Cooperative
Sticky
Assignor
create
Deno
Socket
Factory
create
Kafka
create
Lz4
Provider
create
Node
Socket
Factory
create
Plain
Authenticator
create
Producer
create
Protobuf
Serde
create
Record
create
Sasl
Authenticator
create
Scram
Authenticator
create
Snappy
Provider
create
Zstd
Provider
decode
Add
Offsets
To
Txn
Response
decode
Add
Partitions
To
Txn
Response
decode
Alter
Client
Quotas
Response
decode
Alter
Configs
Response
decode
Alter
Partition
Reassignments
Response
decode
Alter
Replica
Log
Dirs
Response
decode
Alter
User
Scram
Credentials
Response
decode
Api
Versions
Response
decode
Attributes
decode
Consumer
Group
Describe
Response
decode
Consumer
Group
Heartbeat
Response
decode
Create
Acls
Response
decode
Create
Delegation
Token
Response
decode
Create
Partitions
Response
decode
Create
Topics
Response
decode
Delete
Acls
Response
decode
Delete
Groups
Response
decode
Delete
Records
Response
decode
Delete
Topics
Response
decode
Describe
Acls
Response
decode
Describe
Client
Quotas
Response
decode
Describe
Cluster
Response
decode
Describe
Configs
Response
decode
Describe
Delegation
Token
Response
decode
Describe
Groups
Response
decode
Describe
Log
Dirs
Response
decode
Describe
Producers
Response
decode
Describe
Quorum
Response
decode
Describe
Topic
Partitions
Response
decode
Describe
Transactions
Response
decode
Describe
User
Scram
Credentials
Response
decode
Elect
Leaders
Response
decode
End
Txn
Response
decode
Expire
Delegation
Token
Response
decode
Failure
decode
Fetch
Response
decode
Find
Coordinator
Response
decode
Get
Telemetry
Subscriptions
Response
decode
Heartbeat
Response
decode
Incremental
Alter
Configs
Response
decode
Init
Producer
Id
Response
decode
Join
Group
Response
decode
Leave
Group
Response
decode
List
Groups
Response
decode
List
Offsets
Response
decode
List
Partition
Reassignments
Response
decode
List
Transactions
Response
decode
Metadata
Response
decode
Offset
Commit
Response
decode
Offset
Fetch
Response
decode
Offset
For
Leader
Epoch
Response
decode
Produce
Response
decode
Push
Telemetry
Response
decode
Record
Batch
decode
Renew
Delegation
Token
Response
decode
Response
Header
decode
Sasl
Authenticate
Response
decode
Sasl
Handshake
Response
decode
Success
decode
Sync
Group
Response
decode
Txn
Offset
Commit
Response
decode
Update
Features
Response
decode
Wire
Format
Header
default
Partitioner
discover
Brokers
encode
Add
Offsets
To
Txn
Request
encode
Add
Partitions
To
Txn
Request
encode
Alter
Client
Quotas
Request
encode
Alter
Configs
Request
encode
Alter
Partition
Reassignments
Request
encode
Alter
Replica
Log
Dirs
Request
encode
Alter
User
Scram
Credentials
Request
encode
Api
Versions
Request
encode
Attributes
encode
Consumer
Group
Describe
Request
encode
Consumer
Group
Heartbeat
Request
encode
Create
Acls
Request
encode
Create
Delegation
Token
Request
encode
Create
Partitions
Request
encode
Create
Topics
Request
encode
Delete
Acls
Request
encode
Delete
Groups
Request
encode
Delete
Records
Request
encode
Delete
Topics
Request
encode
Describe
Acls
Request
encode
Describe
Client
Quotas
Request
encode
Describe
Cluster
Request
encode
Describe
Configs
Request
encode
Describe
Delegation
Token
Request
encode
Describe
Groups
Request
encode
Describe
Log
Dirs
Request
encode
Describe
Producers
Request
encode
Describe
Quorum
Request
encode
Describe
Topic
Partitions
Request
encode
Describe
Transactions
Request
encode
Describe
User
Scram
Credentials
Request
encode
Elect
Leaders
Request
encode
End
Txn
Request
encode
Expire
Delegation
Token
Request
encode
Fetch
Request
encode
Find
Coordinator
Request
encode
Get
Telemetry
Subscriptions
Request
encode
Heartbeat
Request
encode
Incremental
Alter
Configs
Request
encode
Init
Producer
Id
Request
encode
Join
Group
Request
encode
Leave
Group
Request
encode
List
Groups
Request
encode
List
Offsets
Request
encode
List
Partition
Reassignments
Request
encode
List
Transactions
Request
encode
Metadata
Request
encode
Offset
Commit
Request
encode
Offset
Fetch
Request
encode
Offset
For
Leader
Epoch
Request
encode
Produce
Request
encode
Push
Telemetry
Request
encode
Record
Batch
encode
Renew
Delegation
Token
Request
encode
Request
Header
encode
Sasl
Authenticate
Request
encode
Sasl
Handshake
Request
encode
Sync
Group
Request
encode
Txn
Offset
Commit
Request
encode
Update
Features
Request
encode
Wire
Format
Header
frame
Request
has
Compression
Provider
is
Flexible
Version
json
Serializer
negotiate
Version
parse
Broker
Address
read
Response
Frame
record
Name
Strategy
register
Compression
Provider
request
Header
Version
response
Header
Version
round
Robin
Partitioner
topic
Record
Name
Strategy
References
Alter
Config
Op
GitHub
@qualithm/kafka-client - v0.1.6
Loading...
Native Apache Kafka client for JavaScript and TypeScript runtimes.