Chapter 3. Enhancements
Streams for Apache Kafka 2.8 adds a number of enhancements.
3.1. Streams for Apache Kafka Copy linkLink copied to clipboard!
3.1.1. Kafka 3.8.0 enhancements Copy linkLink copied to clipboard!
For an overview of the enhancements introduced with Kafka 3.8.0, refer to the Kafka 3.8.0 Release Notes.
3.1.2. OAuth 2.0: New JWT validation and client authentication properties Copy linkLink copied to clipboard!
Additional OAuth configuration options have been added for oauth authentication on the listener and the client.
-
On the listener,
oauth.server.bearer.token.locationandoauth.username.prefixhave been added. -
On the client, ` oauth.access.token.location`,
oauth.client.assertion,oauth.client.assertion.location,oauth.client.assertion.type, andsaslExtensionshave been added.
For more information, see Configuring OAuth 2.0 authentication on listeners and Configuring OAuth 2.0 on Java clients.
3.2. Kafka Bridge Copy linkLink copied to clipboard!
3.2.1. Support for OpenAPI v3 Copy linkLink copied to clipboard!
Kafka Bridge now supports OpenAPI v3. Support for OpenAPI v2 is now deprecated.
3.2.2. New support for message timestamps Copy linkLink copied to clipboard!
Producers can now specify a timestamp explicitly in ProducerRecord objects. A timestamp in the ConsumerRecord can also be read in a request response.
-
Set the timestamp on a message sent using the
sendAPI. -
Get the timestamp on receiving a message using the
pollAPI.
For more information, see ProducerRecord and ConsumerRecord.
3.2.3. JSON arrays for record keys and values Copy linkLink copied to clipboard!
The json embedded data format for Kafka messages now supports JSON arrays for record keys and values in the OpenAPI definition.