Dieser Inhalt ist in der von Ihnen ausgewählten Sprache nicht verfügbar.
Chapter 2. Enhancements
AMQ Streams 2.1 adds a number of enhancements.
2.1. Kafka 3.1.0 enhancements Link kopierenLink in die Zwischenablage kopiert!
For an overview of the enhancements introduced with Kafka 3.1.0, refer to the Kafka 3.1.0 Release Notes.
2.2. OAuth configuration options Link kopierenLink in die Zwischenablage kopiert!
New OAuth configuration properties have been introduced to the OAuth authentication configuration.
The properties related to timeouts and extracting groups information.
Timout properties
-
oauth.connect.timeout.secondsspecifies the maximum time in seconds to connect to an authorization server before a timeout. -
oauth.read.timeout.secondsspecifies the maximum time in seconds to read from an authorization server before a timeout.
The default is sixty seconds for both.
Groups properties
-
oauth.groups.claimspecifies a JsonPath query to extract groups information from a JWT token or introspection endpoint response. Not set by default. -
oauth.groups.claim.delimiterspecifies a delimiter to parse groups information when returned as a single delimited string. The default value is ',' (comma).
Example OAuth configuration for a Kafka broker listener
listener.name.client.oauthbearer.sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required \
# ...
oauth.connect.timeout.seconds=60
oauth.read.timeout.seconds=60
oauth.groups.claim="$.groups"
oauth.groups.claim.delimiter=","