kafkajs - npm Package Versions

[0.6.8] - 2017-12-27

Fixed

• Only use seed brokers to bootstrap consumers (introduced a broker pool abstraction) #19
• Don't include the size of the size field when determining if the buffer has enough bytes to read the full response #20

[0.6.7] - 2017-12-18

Fixed

• Don't throw KafkaJSOffsetOutOfRange on every protocol error

[0.6.6] - 2017-12-15

Fixed

• Fix index out of range errors when decoding partial messages #11
• Don't rely on seed broker for finding group coordinator #13

[0.6.5] - 2017-12-14

Fixed

• Fix partial message decode #10
• Throw not implemented error for Snappy and LZ4 compression #10
• Don't crash when setting offsets to default #10

[0.6.4] - 2017-12-13

Added

• Add stack trace to connection error logs

Changed

• Skip consumer callback error logs for kafkajs errors

Fixed

• Use the connection timeout callback for socket timeout
• Check if still connected before writing to the socket

[0.6.3] - 2017-12-11

Added

• Add error logs for user errors in eachMessage and eachBatch

Fixed

• Recover from rebalance in progress when starting the consumer

[0.6.2] - 2017-12-11

Added

• Add logger: "kafkajs" to log lines

[0.6.1] - 2017-12-08

Added

• Add latest Kafka error codes

Fixed

• Add fallback error for unsupported error codes

[0.6.0] - 2017-12-07

Added

• Expose consumer group isRunning to eachBatch
• Add offsetLag to consumer batch

[0.5.0] - 2017-12-04

Added

• Add ability to subscribe to events (heartbeats and offsets commit) #4