All notable changes to this project will be documented in this file.
The format is based on Keep a Changelog, and this project adheres to Semantic Versioning.
1.8.1 - 2023-12-01
- [kafka] Added
c
andcompression
argument, to select compression algorithm for producer (by @flecno)
- [common] Updated kafka, commons-text and rabbitmq library
- [common] Updated build to JDK 17
- [common] Updated github-action versions
- [kafka] Changed default compression for producers from lz4 to snappy (by @flecno)
1.8.0 - 2021-03-17
- [common] Migrated plunger to JDK 11
- [common] Added CHANGELOG.md
- [kafka] Added
tx
andtxTimeout
argument, to enable transactional producer (by @flecno) - [kafka] Added
async
argument, where a Callback is used (by @flecno)
- [common] Updated jansi library (by @flecno)
- [common] Improved output performance (by @flecno)
- [kafka] Enabled lz4 compression for producers (by @flecno)
- [kafka] Increased producer batch-size-config from 16384 to 100k (by @flecno)
- [kafka] Increased producer linger-ms-config from 1 to 50 (by @flecno)
1.7.1 - 2019-07-15
- [kafka] Improved schema-registry URL behavior for kafka provider.
- [kafka] Changed kafka timeout default from 1s to 4s.
1.7.0 - 2019-07-11
- [kafka] Added support for avro-schemas to the kafka provider (by @clairefautsch and @eberdt)
- [kafka] Updated rabbitmq library (Security CVE)
- [kafka] Updated kafka library
1.6.2 - 2018-10-05
- [common] Added JAVA_OPTS environment variable support
1.6.1 - 2018-04-16
- [rabbitmq] Fixed minor api-change in rabbitmq with newer versions (3.6.x).
1.6.0 - 2018-02-26
- [kafka] Support for kafka-headers
- [kafka] Kafka-Client update to 1.0.0
- [kafka] Renamed kafka meta-data headers, now starting with
kafka.
1.5.9 - 2017-11-01
- [kafka] Kafka option
acks
for producer, defaults toall
.
1.5.8 - 2017-11-01
- [kafka] changed commitSync behaviour for kafka provider cat command.
1.5.7 - 2017-07-07
- [kafka] Added
maxPartitionFetchBytes
- Sets themax.partition.fetch.bytes
option for the kafka consumer (pcat) - [kafka] Added
maxRequestSize
- Sets themax.request.size option
for the kafka producer (pput)
1.5.6 - 2017-03-22
- [common] Added
-d
option toput
, so you can pass lines with plain content directly to the message broker (each line a message, unescaped, without header). - [kafka] Added
maxPollRecords
parameter to kafka provider
1.5.5 - 2017-03-01
- [kafka] Sort output of kafka topics when using command
ls
1.5.4 - 2017-02-15
- [kafka] NPE
fix
for key parameter handling in kafka provider
- [kafka] key parameter behaviour improved (will use plunger
key
parameter, orkey
message-header)
- [kafka] Removed JMX calls for kafka
ls
command