A modern Apache Kafka client for node.js
admin.fetchOffsets
to resolve the offsets #895admin.deleteTopicRecords
#905GROUP_JOIN
event on stale partition assignments #937UNKNOWN_TOPIC_OR_PARTITION
check for addMultipleTargetTopics
#938ConfigResourceTypes
) #898onError
handler #944onTimeout
handler #956This is a large release containing fixes and features from a multitude of contributors. Some notable changes:
KafkaMessage.value
from Buffer
to Buffer | null
. This was in fact always the behavior at runtime, so this change is just fixing a bug in the types - but it will require you to handle the value being null
for your project to build.logLevel
argument of logCreator
#538throttle_time_ms
to 0 if missing in ApiVersions
response #495randomBytes()
#462IHeaders
type definition (from string to Buffer) #467ResourceType
to ResourceTypes
#468configNames
optional in ResourceTypes
#474transactionState.ABORTING
value #478consumer.commitOffsets
for manual committing #436fetchTopicMetadata
return type #433