v4.0.0
This release targets Kafka 4.0.0. It only works in KRaft mode (Zookeeper is no longer used).
Major changes
- Java 17+: as Kafka Server 4.x requires Java 17+, so does embedded-kafka even though Kafka Clients/Streams are still available for Java 11+.
- Scala 2.13+: Kafka is not compiled against Scala 2.12 anymore, so does embedded-kafka.
- embedded-kafka 4.0.0 starts a Kafka server in combined mode (broker and controller) and no more a Zookeeper server.
Changes required in your code
As a user, you'll have to change your code to use controllerPort
instead of zookeeperPort
in places you were doing so:
- EmbeddedKafkaConfig(kafkaPort = 12345, zooKeeperPort = 54321)
+ EmbeddedKafkaConfig(kafkaPort = 12345, controllerPort = 54321)
Other changes
- feat: upgrade to Kafka 4.0.0 by @gaeljw in #562
- Update scala-library to 2.13.16 by @scala-steward in #540
- Update scala3-library to 3.3.5 by @scala-steward in #549
- Update sbt, scripted-plugin to 1.10.11 by @scala-steward in #559
Full Changelog: v3.9.0...v4.0.0