Alpakka Kafka 3.0.x
Note
In case you are browsing a specific version’s documentation: check out the latest release notes
3.0.1
Noteworthy
This version bumped the kafka client which changes a default config as mentiond here. The following error can show up in the logs:
org.apache.kafka.common.errors.ClusterAuthorizationException: Cluster authorization failed
In that case the following config needs to be provided in order to set the right default:
akka.kafka.producer.kafka-clients.enable.idempotence=false