2020-02-24, Version 5.0.0

• upgraded dependencies
• BREAKING please note that the latest sinek (kafka-client) will not install the native kafka client dependency node-rdkafka anymore. In case you are using the native client with kafka-streams or kafka-connect you have to install it manually (see below).

A note on native mode

If you are using the native mode (config: { noptions: {} }). You will have to manually install node-rdkafka alongside kafka-streams. (This requires a Node.js version between 9 and 12 and will not work with Node.js >= 13, last tested with 12.16.1)

On Mac OS High Sierra / Mojave: CPPFLAGS=-I/usr/local/opt/openssl/include LDFLAGS=-L/usr/local/opt/openssl/lib yarn add --frozen-lockfile node-rdkafka@2.7.4

Otherwise: yarn add --frozen-lockfile node-rdkafka@2.7.4

(Please also note: Doing this with npm does not work, it will remove your deps, npm i -g yarn)

2019-07-04, Version 4.12.0

• upgraded dependencies
• fixed issue #91
• added topic extractor example

2019-05-16, Version 4.11.0

• added continueWith dsl operation

2019-05-13, Version 4.10.0

• fixed typo that broke window functionality
• correctly handling rejection of .to() promise call
• correctly handling produce errors (make sure to sub kafkaStreams.on("error", (error) => {...});)
• KStream.branch([...]) now returns stream clones that consist of deeply cloned events
• KStream.clone(cloneObjects = false, cloneDeep = false) now offers optional parameters to clone the stream events, otherwise mutating the origin stream will alter the cloned stream's objects
• hardened the StreamDSL JSON convenience methods
• other small refactorings

2019-05-07, Version 4.9.0

• upgraded dependencies
• fixed bug where kstream merge was not passing kafkaStreams reference
• fixed code formatting
• fixed word-count example
• fixed produceToTopic example
• fixed consumeOneProduceTwo example
• adjusted consumeFromTopic example
• ported most-subject back to 5.3.0 to fix major window bug
• fixed window example

2019-09-01, Version 4.8.0

• fixed bug in type declarations
• fixed typo in quick-start docu
• fixed bug in window (createSubject; most-subject switched from async to create..)
• upgraded dependencies (newest native client)

2018-09-10, Version 4.7.0

• now referencing new kafka client type (advanced configs) declarations
• upgrade dependencies (kafka clients)

2018-09-10, Version 4.6.5

• again fix on type declaration for .to() sorry

2018-08-10, Version 4.6.4

• removed ncu as dependency, should not have been added after all
• alloing "auto" as partition count param for .to() call
• upgraded sinek from 6.22.2 to 6.22.3

2018-21-09, Version 4.6.3

• made topic optional in ts definition for .to() call