For installation instructions check out the getting started guide.
Added
- The
mqtt
input and output now support sending a last will, configuring a keep alive timeout, and setting retained out output messages. - Go API: New stream builder
AddBatchProducerFunc
andAddBatchConsumerFunc
methods. - Field
gzip_compression
added to theelasticsearch
output. - The
redis_streams
input now supports creating the stream with theMKSTREAM
command (enabled by default). - The
kafka
output now supports manual partition allocation using interpolation functions in the fieldpartition
.
Fixed
- The bloblang method
contains
now correctly compares numerical values in arrays and objects.
The full change log can be found here.