v1.8.1

Added

• [kafka] Added c and compression argument, to select compression algorithm for producer (by @flecno)

Changed

• [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)

v1.8.0

Added

• [common] Migrated plunger to JDK 11
• [common] Added CHANGELOG.md
• [kafka] Added tx and txTimeout argument, to enable transactional producer (by @flecno)
• [kafka] Added async argument, where a Callback is used (by @flecno)

Changed

• [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)

v1.7.1

• Improved schema-registry URL behavior for kafka provider.
• Changed kafka timeout default from 1s to 4s.

v1.7.0

• Added support for avro-schemas to the kafka provider (kudos to @clairefautsch and @eberdt)
• Updated rabbitmq library (Security CVE)
• Updated kafka library

v1.6.2

• Added JAVA_OPTS environment variable support

v1.6.1

• Fixed minor api-change in rabbitmq with newer versions (3.6.x).

v1.6.0

• Kafka-Client update to 1.0.0
• Support for kafka-headers
• Renamed kafka meta-data headers, now starting with kafka.

v1.5.9

• Kafka option acks for producer, defaults to all.

v1.5.8

• changed commitSync behaviour for kafka provider cat command.

v1.5.7

• Added maxPartitionFetchBytes - Sets the max.partition.fetch.bytes option for the kafka consumer (pcat)
• Added maxRequestSize - Sets the max.request.size option for the kafka producer (pput)