v0.5.1

Bugfix on hkt version command to always show accurate version. In order to accomplish this, this is now dynamically calculated. #45

v0.5.0

Forbid sending messages to Kafka with null as value #44

v0.4.0

• Add none valuecodec to avoid printing message content

v0.3.0

• Fetch from upstream latest changes #36
• Upgrade dependencies and give support from go v1.15 onwards #41
• New feature: Produce Avro formatted messages #38 #39 #40

Avro formatted messages production

1. Using latest version available using TopicNameStrategy to know the schema subject to use:

# subject: "actors-value"
echo '{"value": {"FirstName": "Ryan"}, "key": "id-42"}' | hkt produce -topic actors -registry http://localhost:8081 -valuecodec avro

2. Using latest version available using TopicRecordNameStrategy to know the schema subject to use:

# subject: "actors-record"
echo '{"value": {"FirstName": "Ryan"}, "key": "id-42"}' | hkt produce -topic actors -registry http://localhost:8081 -valuecodec avro -value-avro-record-name record

3. Using schema provided in -value-avro-schema-file parameter:

echo '{"value": {"FirstName": "Ryan"}, "key": "id-42"}' | hkt produce -topic actors -registry http://localhost:8081 -valuecodec avro -value-avro-schema-file file.avsc

4. Using schema unique identifier provided in -value-avro-schema-id parameter:

echo '{"value": {"FirstName": "Ryan"}, "key": "id-42"}' | hkt produce -topic actors -registry http://localhost:8081 -valuecodec avro -value-avro-schema-id 100

v0.2.0

• Add murmur2 as available key partitioner to produce and consume messages #34
• Upgrade dependencies

v0.1.1

Upgrade dependencies: heetch/avro v0.2.6, golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550 and github.com/frankban/quicktest v1.10.0

v0.1.0

This release:

• adds support for decoding Avro messages (consuming only so far). #25 Thanks to @gillesfabio
• fixes an panic when talking to a broker that returns an unresolvable peer address. #29
• adds support for certificateless TLS. #24 Thanks to @dangogh

Fix default port behavior

This applies a minor fix to the current release, making port numbers in the kafka broker addresses default to 9092 as previously.

Initial hkt release

Although hkt is forked from kt, it has enough backwardly incompatible changes (not to mention a new name) that we're going to start releases from zero.

Changes to the hkt consume command:

• timestamp and duration support
• key filtering support
• better support for JSON messages
• positional args for topic and offsets
• messages from multiple topics are timestamp-ordered
• removed support for consumer-group consuming
• removed support for $KT_TOPIC

Changes to other commands:

• removed support for $KT_TOPIC
• remove -partition flag from hkt produce
• better partitioner support in producer
• consistent flag for specifying message/key codecs

General changes:

• All round code simplification
• Better system tests