Alpakka Kafka 3.0.x


In case you are browsing a specific version’s documentation: check out the latest release notes



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:

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.