Chapter 4. Technology Previews Technology Preview features included with Streams for Apache Kafka 2.7. Important Technology Preview features are not supported with Red Hat production service-level agreements (SLAs) and might not be functionally complete; therefore, Red Hat does not recommend implementing any Technology Preview features in production environments. This Technology Preview feature provides early access to upcoming product innovations, enabling you to test functionality and provide feedback during the development process. For more information about the support scope, see Technology Preview Features Support Scope . 4.1. KRaft mode KRaft mode is available as a technology preview. Currently, KRaft mode in Streams for Apache Kafka has the following limitations: Only the Unidirectional Topic Operator is supported in KRaft mode. The Bidirectional Topic Operator is not supported and when the UnidirectionalTopicOperator feature gate is disabled, the spec.entityOperator.topicOperator property must be removed from the Kafka custom resource. JBOD storage is not supported. The type: jbod storage can be used, but the JBOD array can contain only one disk. Scaling of KRaft controller-only nodes up or down is not supported. Unregistering Kafka nodes removed from the Kafka cluster. 4.2. Streams for Apache Kafka Console A console (user interface) for Streams for Apache Kafka is now available as a technology preview. The Streams for Apache Kafka Console is designed to seamlessly integrate with your Streams for Apache Kafka deployment, providing a centralized hub for monitoring and managing Kafka clusters. Deploy the console and connect it to your Kafka clusters managed by Streams for Apache Kafka. Gain insights into each connected cluster through dedicated pages covering brokers, topics, and consumer groups. View essential information, such as the status of a Kafka cluster, before looking into specific information about brokers, topics, or connected consumer groups. See the Streams for Apache Kafka Console guide . 4.3. Streams for Apache Kafka Proxy Streams for Apache Kafka Proxy is an Apache Kafka protocol-aware proxy designed to enhance Kafka-based systems. Through its filter mechanism it allows additional behavior to be introduced into a Kafka-based system without requiring changes to either your applications or the Kafka cluster itself. As part of the technology preview, you can try the Streams for Apache Kafka Proxy Record Encryption filter. The filter uses industry-standard cryptographic techniques to apply encryption to Kafka messages, ensuring the confidentiality of data stored in the Kafka Cluster. See the Streams for Apache Kafka Proxy guide . 4.4. Kafka Static Quota plugin configuration Use the technology preview of the Kafka Static Quota plugin to set throughput and storage limits on brokers in your Kafka cluster. You enable the plugin and set limits by configuring the Kafka resource. You can set a byte-rate threshold and storage quotas to put limits on the clients interacting with your brokers. Example Kafka Static Quota plugin configuration apiVersion: kafka.strimzi.io/v1beta2 kind: Kafka metadata: name: my-cluster spec: kafka: # ... config: client.quota.callback.class: io.strimzi.kafka.quotas.StaticQuotaCallback client.quota.callback.static.produce: 1000000 client.quota.callback.static.fetch: 1000000 client.quota.callback.static.storage.soft: 400000000000 client.quota.callback.static.storage.hard: 500000000000 client.quota.callback.static.storage.check-interval: 5 See Setting limits on brokers using the Kafka Static Quota plugin .

Commands:
apiVersion: kafka.strimzi.io/v1beta2 kind: Kafka metadata: name: my-cluster spec: kafka: # config: client.quota.callback.class: io.strimzi.kafka.quotas.StaticQuotaCallback client.quota.callback.static.produce: 1000000 client.quota.callback.static.fetch: 1000000 client.quota.callback.static.storage.soft: 400000000000 client.quota.callback.static.storage.hard: 500000000000 client.quota.callback.static.storage.check-interval: 5