Chapter 2. Enhancements
Chapter 2. Enhancements AMQ Streams 2.1 adds a number of enhancements. 2.1. Kafka 3.1.0 enhancements 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 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.seconds specifies the maximum time in seconds to connect to an authorization server before a timeout. oauth.read.timeout.seconds specifies 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.claim specifies a JsonPath query to extract groups information from a JWT token or introspection endpoint response. Not set by default. oauth.groups.claim.delimiter specifies 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="USD.groups" oauth.groups.claim.delimiter="," See Rebalance performance tuning .
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="USD.groups" oauth.groups.claim.delimiter=","