v0.8.2
New release version v0.8.2
Producer API Changes
- Added new producer method,
setPollInterval(interval)
. If you simply want to poll for events on an interval, you can pass it here without needing to manage connections or disconnections. - Fixed some bugs that would be related to manually connecting/disconnecting when using the producer stream.
- Producer stream now only uses topic objects if topic options are provided.
Consumer API Changes
- Added new consumer methods,
commitMessage
andcommitMessageSync
. When committing a message instead of a topic partition, these methods will commit the proper offsets instead of the off-by-one issue seen prior.