Skip to content

v4.0.0

Compare
Choose a tag to compare
@gaeljw gaeljw released this 13 Apr 11:59
· 12 commits to master since this release
c8bca4c

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

Full Changelog: v3.9.0...v4.0.0