v1.3.1
v1.3.1 is a maintenance release. It is supported for all usage.
Fixes
- Avoid a race condition that causes 100% usage of a CPU core when consuming with
partitionsConsumedConcurrently > 1
and all messages are consumed (#300). - Fix type definition for
Kafka()
constructor and for passing topic configurations to theproducer()
andconsumer()
in the promisified API (@davidkhala, #297, #321).