A modern Apache Kafka client for node.js
alterPartitionReassignments
& listPartitionReassignments
#1419pause
function to eachMessage
/eachBatch
to pause the current topic-partition #1364KafkaMessage
type is now a union between the pre-Kafka 0.10 message format and the current #1401⚠️ This is the first major version released in 4 years, and contains a few important breaking changes. A migration guide has been prepared to help with the migration process. Be sure to read it before upgrading from older versions of KafkaJS.
Big thanks to @priitkaard for contributing some amazing performance improvements included in this release! Expect to see higher throughput and more efficient resource utilization compared to previous versions, especially in scenarios where you have an uneven distribution of messages across partitions.
topics
argument for consumer.subscribe
to subscribe to multiple topics #1313ResourceTypes
#1334topic
from admin.fetchOffsets
#1335getTopicMetadata
from admin client #1336TopicPartitionOffsetAndMedata
#1338cause
#1341eachMessage
handler #1255rebalancing
consumer event #1067 #1079configSource
in admin.decribeConfigs
#1023topics
property to admin.fetchOffsets
to fetch offsets for multiple topics #992 #998admin.createTopic
#1104brokers
list contains strings #1284consumer.seek
when autoCommit
is false
#1012warn
#1279offset
type of consumer.seek
#981null
key #1037heartbeatInterval
when invoking heartbeat
concurrently #1026timestamp
of LoggerEntryContent
to be string #1082admin.describeAcls
#1118DISCONNECTING
state if in-flight requests time out during disconnect #1208admin.deleteTopicRecords
with offset -1
#1265