Release v1.4.2

Added

• Add QueueSubscriber Option for JetstreamToKafka. Thanks to @aonurdemir for the contribution (#89)

connect: [
  {
      type: "JetStreamToKafka",
      id: "Telemetry",
      subject: "my-subscription.>",
      durablename: "bridge-consumer",
      queuename: "bridge-consumer"
      stream: my-stream
      startatsequence: 0
  }
]

• Add SASL TLS option to always use tls (#96)

connect: [
  {
      sasl: {
        "user": "kafka-admin",
        "password": "kafka-secret",
        "mechanism": "scram-sha-512",
	"tls": true
      }
  }
]

Full Changelog: v1.4.1...v1.4.2

Release v1.4.1

Added

• Support bind stream option for JetStream #95

Full Changelog: v1.4.0...v1.4.1

Release v1.4.0

Fixed

• Fixed Kafka bug with consumer groups and timeouts during repartitioning (#80)

Changed

• Update kafka dependency from Shopify/sarama to IBM/sarama (#93)
• Update NATS client dependencies (#92)

Release v1.3.0

Changelog

Added

• Message header forward to NATSToKafka connector. Thanks to @rpuppo for the contribution (#63)
• Kafka SASL mechanism options (SCRAM SHA256/SHA512). Thanks to @noamsan for the contribution (#71)

Updated

• Dependencies (#76)

Fixed

• External links in README. Thanks to @navinpai for the contribution (#74)

Docker

https://hub.docker.com/r/natsio/nats-kafka/tags

docker pull natsio/nats-kafka:1.3.0

Complete Changes

v1.2.2...v1.3.0

Release v1.2.2

Fixes

• Message indexes array length and contents are not written correctly causing the deserialization to fail

Docker

https://hub.docker.com/r/natsio/nats-kafka/tags

docker pull natsio/nats-kafka:1.2.2

Release v1.2.1

Fixed

• Fix bug in Protobuf serializer

Docker

https://hub.docker.com/r/natsio/nats-kafka/tags

docker pull natsio/nats-kafka:1.2.1

Release v1.2.0

Added

• Schema registry support for sending and receiving Avro, JSON and protobuf encoded messages

Docker

docker pull natsio/nats-kafka:1.2.0

Release v1.1.0

Added

• Support for LeastBytes partitioner

Docker

docker pull natsio/nats-kafka:1.1.0

Release v1.0.0

Added

• JetStream support
• NATS, STAN, and JetStream configuration file examples

Fixed

• Passing invalid config file path now fails
• Version is now correctly displayed

Docker

docker pull natsio/nats-kafka:1.0.0

Release v0.2.1

Support connections with SASL and TLS

Currently, users can only choose between SASL and TLS insecure skip verify and
full TLS. This change allows users to use SASL with full TLS.

Docker Image

docker pull natsio/nats-kafka:0.2.1