Waterstream Change Log

1.3.X

1.3.15

  • Optimize SUBSCRIBE latency

  • Optimize historical messages processing

1.3.14

  • Changed default Kafka publishing settings linger.ms and batch.size to optimize for throughput

  • Ability to specify max.block.ms and buffer.memory for Kafka producer

  • Customize HTTP port of the Devbox. Change default from 80 to 8080

  • Docker repository name changed from simplematter/waterstream-kafka-minified to simplematter/waterstream-kafka, from simplematter/waterstream-kafka-arm64v8-minified to simplematter/waterstream-kafka-arm64v8, docker repositories became public (but still needing the license to run).

1.3.13

  • Optimize the session load time

1.3.12

  • Ability to specify replication.factor for Kafka Streams

1.3.11

  • Docker images logs customization with WATERSTREAM_LOGBACK_CONFIG

  • Fix MQTT v 5.0 error code for invalid client ID

1.3.10

  • Devbox Docker image which includes ZooKeeper, Kafka, Waterstream and MQTT Board

  • Safer base image for Docker images: openjdk:16-oraclelinux8

1.3.9

  • Optimize session state persistence

1.3.8

  • Bugfix: MQTT v 3.1.1 bridge topic subscription

1.3.7

  • Bugfix: if AUTHENTICATION_METHOD_CLIENT_SSL_CERT_ENABLED is true and AUTHENTICATION_REQUIRED is false client SSL certificate is optional now

  • Add Prometheus metric mqtt_proxy_publish_to_kafka_backlog to track the lag between incoming MQTT messages and publishing to Kafka

1.3.5

  • Ability to specify inline license data in WATERSTREAM_LICENSE_DATA environment variable.

1.3.4

  • Default value for KAFKA_STREAMS_APP_SERVER_HOST is now taken from InetAddress.getLocalHost().getCanonicalHostName() instead of disabling streams app server if it’s not specified.

1.3.3

  • MQTT v5 - shared subscriptions

  • MQTT v5 - subscription IDs

1.3.2

  • MQTT v5 - Last Will delay

  • MQTT v5 - topic aliases

1.3.1

Bugfix:

  • Deduplicate retained messages if topic patterns in SUBSCRIBE packet match the topic multiple times

  • Resolve environment variables in the bridge config file

  • MQTT5: support multiple user properties with the same key

1.3.0

1.2.X

1.2.1

  • MQTT-Kafka topic mapping by prefix. In particular, it simplifies reading ksqlDB results back into MQTT. See MQTT to Kafka topic mapping for the details