Jump To Close Expand all Collapse all Table of contents Using AMQ Streams on OpenShift Making open source more inclusive 1. Overview of AMQ Streams Expand section "1. Overview of AMQ Streams" Collapse section "1. Overview of AMQ Streams" 1.1. Kafka capabilities 1.2. Kafka use cases 1.3. How AMQ Streams supports Kafka 1.4. AMQ Streams Operators Expand section "1.4. AMQ Streams Operators" Collapse section "1.4. AMQ Streams Operators" 1.4.1. Cluster Operator 1.4.2. Topic Operator 1.4.3. User Operator 1.5. AMQ Streams custom resources Expand section "1.5. AMQ Streams custom resources" Collapse section "1.5. AMQ Streams custom resources" 1.5.1. AMQ Streams custom resource example 1.6. Listener configuration 1.7. Document Conventions 2. Deployment configuration Expand section "2. Deployment configuration" Collapse section "2. Deployment configuration" 2.1. Kafka cluster configuration Expand section "2.1. Kafka cluster configuration" Collapse section "2.1. Kafka cluster configuration" 2.1.1. Configuring Kafka 2.1.2. Configuring the Entity Operator Expand section "2.1.2. Configuring the Entity Operator" Collapse section "2.1.2. Configuring the Entity Operator" 2.1.2.1. Entity Operator configuration properties 2.1.2.2. Topic Operator configuration properties 2.1.2.3. User Operator configuration properties 2.1.3. Kafka and ZooKeeper storage types Expand section "2.1.3. Kafka and ZooKeeper storage types" Collapse section "2.1.3. Kafka and ZooKeeper storage types" 2.1.3.1. Data storage considerations Expand section "2.1.3.1. Data storage considerations" Collapse section "2.1.3.1. Data storage considerations" 2.1.3.1.1. File systems 2.1.3.1.2. Apache Kafka and ZooKeeper storage 2.1.3.2. Ephemeral storage Expand section "2.1.3.2. Ephemeral storage" Collapse section "2.1.3.2. Ephemeral storage" 2.1.3.2.1. Log directories 2.1.3.3. Persistent storage Expand section "2.1.3.3. Persistent storage" Collapse section "2.1.3.3. Persistent storage" 2.1.3.3.1. Storage class overrides 2.1.3.3.2. Persistent Volume Claim naming 2.1.3.3.3. Log directories 2.1.3.4. Resizing persistent volumes 2.1.3.5. JBOD storage overview Expand section "2.1.3.5. JBOD storage overview" Collapse section "2.1.3.5. JBOD storage overview" 2.1.3.5.1. JBOD configuration 2.1.3.5.2. JBOD and Persistent Volume Claims 2.1.3.5.3. Log directories 2.1.3.6. Adding volumes to JBOD storage 2.1.3.7. Removing volumes from JBOD storage 2.1.4. Scaling clusters Expand section "2.1.4. Scaling clusters" Collapse section "2.1.4. Scaling clusters" 2.1.4.1. Scaling Kafka clusters Expand section "2.1.4.1. Scaling Kafka clusters" Collapse section "2.1.4.1. Scaling Kafka clusters" 2.1.4.1.1. Adding brokers to a cluster 2.1.4.1.2. Removing brokers from a cluster 2.1.4.2. Partition reassignment Expand section "2.1.4.2. Partition reassignment" Collapse section "2.1.4.2. Partition reassignment" 2.1.4.2.1. Reassignment JSON file 2.1.4.2.2. Reassigning partitions between JBOD volumes 2.1.4.3. Generating reassignment JSON files 2.1.4.4. Creating reassignment JSON files manually 2.1.4.5. Reassignment throttles 2.1.4.6. Scaling up a Kafka cluster 2.1.4.7. Scaling down a Kafka cluster 2.1.5. Maintenance time windows for rolling updates Expand section "2.1.5. Maintenance time windows for rolling updates" Collapse section "2.1.5. Maintenance time windows for rolling updates" 2.1.5.1. Maintenance time windows overview 2.1.5.2. Maintenance time window definition 2.1.5.3. Configuring a maintenance time window 2.1.6. Connecting to ZooKeeper from a terminal 2.1.7. Deleting Kafka nodes manually 2.1.8. Deleting ZooKeeper nodes manually 2.1.9. List of Kafka cluster resources 2.2. Kafka Connect/S2I cluster configuration Expand section "2.2. Kafka Connect/S2I cluster configuration" Collapse section "2.2. Kafka Connect/S2I cluster configuration" 2.2.1. Configuring Kafka Connect 2.2.2. Kafka Connect configuration for multiple instances 2.2.3. Configuring Kafka Connect user authorization 2.2.4. Performing a restart of a Kafka connector 2.2.5. Performing a restart of a Kafka connector task 2.2.6. Migrating from Kafka Connect with S2I to Kafka Connect 2.2.7. List of Kafka Connect cluster resources 2.2.8. List of Kafka Connect (S2I) cluster resources 2.2.9. Integrating with Debezium for change data capture 2.3. Kafka MirrorMaker cluster configuration Expand section "2.3. Kafka MirrorMaker cluster configuration" Collapse section "2.3. Kafka MirrorMaker cluster configuration" 2.3.1. Configuring Kafka MirrorMaker 2.3.2. List of Kafka MirrorMaker cluster resources 2.4. Kafka MirrorMaker 2.0 cluster configuration Expand section "2.4. Kafka MirrorMaker 2.0 cluster configuration" Collapse section "2.4. Kafka MirrorMaker 2.0 cluster configuration" 2.4.1. MirrorMaker 2.0 data replication 2.4.2. Cluster configuration Expand section "2.4.2. Cluster configuration" Collapse section "2.4.2. Cluster configuration" 2.4.2.1. Bidirectional replication (active/active) 2.4.2.2. Unidirectional replication (active/passive) 2.4.2.3. Topic configuration synchronization 2.4.2.4. Data integrity 2.4.2.5. Offset tracking 2.4.2.6. Synchronizing consumer group offsets 2.4.2.7. Connectivity checks 2.4.3. ACL rules synchronization 2.4.4. Synchronizing data between Kafka clusters using MirrorMaker 2.0 2.4.5. Performing a restart of a Kafka MirrorMaker 2.0 connector 2.4.6. Performing a restart of a Kafka MirrorMaker 2.0 connector task 2.5. Kafka Bridge cluster configuration Expand section "2.5. Kafka Bridge cluster configuration" Collapse section "2.5. Kafka Bridge cluster configuration" 2.5.1. Configuring the Kafka Bridge 2.5.2. List of Kafka Bridge cluster resources 2.6. Customizing OpenShift resources Expand section "2.6. Customizing OpenShift resources" Collapse section "2.6. Customizing OpenShift resources" 2.6.1. Customizing the image pull policy 2.7. Configuring pod scheduling Expand section "2.7. Configuring pod scheduling" Collapse section "2.7. Configuring pod scheduling" 2.7.1. Specifying affinity, tolerations, and topology spread constraints Expand section "2.7.1. Specifying affinity, tolerations, and topology spread constraints" Collapse section "2.7.1. Specifying affinity, tolerations, and topology spread constraints" 2.7.1.1. Use pod anti-affinity to avoid critical applications sharing nodes 2.7.1.2. Use node affinity to schedule workloads onto specific nodes 2.7.1.3. Use node affinity and tolerations for dedicated nodes 2.7.2. Configuring pod anti-affinity in Kafka components 2.7.3. Configuring node affinity in Kafka components 2.7.4. Setting up dedicated nodes and scheduling pods on them 2.8. External logging Expand section "2.8. External logging" Collapse section "2.8. External logging" 2.8.1. Creating a ConfigMap for logging 3. Configuring external listeners Expand section "3. Configuring external listeners" Collapse section "3. Configuring external listeners" 3.1. Accessing Kafka using node ports 3.2. Accessing Kafka using loadbalancers 3.3. Accessing Kafka using ingress 3.4. Accessing Kafka using OpenShift routes 4. Managing secure access to Kafka Expand section "4. Managing secure access to Kafka" Collapse section "4. Managing secure access to Kafka" 4.1. Security options for Kafka Expand section "4.1. Security options for Kafka" Collapse section "4.1. Security options for Kafka" 4.1.1. Listener authentication Expand section "4.1.1. Listener authentication" Collapse section "4.1.1. Listener authentication" 4.1.1.1. Mutual TLS authentication 4.1.1.2. SCRAM-SHA-512 authentication 4.1.1.3. Network policies 4.1.1.4. Additional listener configuration options 4.1.2. Kafka authorization Expand section "4.1.2. Kafka authorization" Collapse section "4.1.2. Kafka authorization" 4.1.2.1. Super users 4.2. Security options for Kafka clients Expand section "4.2. Security options for Kafka clients" Collapse section "4.2. Security options for Kafka clients" 4.2.1. Identifying a Kafka cluster for user handling 4.2.2. User authentication Expand section "4.2.2. User authentication" Collapse section "4.2.2. User authentication" 4.2.2.1. TLS Client Authentication 4.2.2.2. SCRAM-SHA-512 Authentication 4.2.3. User authorization Expand section "4.2.3. User authorization" Collapse section "4.2.3. User authorization" 4.2.3.1. ACL rules 4.2.3.2. Super user access to Kafka brokers 4.2.3.3. User quotas 4.3. Securing access to Kafka brokers Expand section "4.3. Securing access to Kafka brokers" Collapse section "4.3. Securing access to Kafka brokers" 4.3.1. Securing Kafka brokers 4.3.2. Securing user access to Kafka 4.3.3. Restricting access to Kafka listeners using network policies 4.4. Using OAuth 2.0 token-based authentication Expand section "4.4. Using OAuth 2.0 token-based authentication" Collapse section "4.4. Using OAuth 2.0 token-based authentication" 4.4.1. OAuth 2.0 authentication mechanisms 4.4.2. OAuth 2.0 Kafka broker configuration Expand section "4.4.2. OAuth 2.0 Kafka broker configuration" Collapse section "4.4.2. OAuth 2.0 Kafka broker configuration" 4.4.2.1. OAuth 2.0 client configuration on an authorization server 4.4.2.2. OAuth 2.0 authentication configuration in the Kafka cluster 4.4.2.3. Fast local JWT token validation configuration 4.4.2.4. OAuth 2.0 introspection endpoint configuration 4.4.3. Session re-authentication for Kafka brokers 4.4.4. OAuth 2.0 Kafka client configuration 4.4.5. OAuth 2.0 client authentication flow Expand section "4.4.5. OAuth 2.0 client authentication flow" Collapse section "4.4.5. OAuth 2.0 client authentication flow" 4.4.5.1. Example client authentication flows 4.4.6. Configuring OAuth 2.0 authentication Expand section "4.4.6. Configuring OAuth 2.0 authentication" Collapse section "4.4.6. Configuring OAuth 2.0 authentication" 4.4.6.1. Configuring Red Hat Single Sign-On as an OAuth 2.0 authorization server 4.4.6.2. Configuring OAuth 2.0 support for Kafka brokers 4.4.6.3. Configuring Kafka Java clients to use OAuth 2.0 4.4.6.4. Configuring OAuth 2.0 for Kafka components 4.5. Using OAuth 2.0 token-based authorization Expand section "4.5. Using OAuth 2.0 token-based authorization" Collapse section "4.5. Using OAuth 2.0 token-based authorization" 4.5.1. OAuth 2.0 authorization mechanism Expand section "4.5.1. OAuth 2.0 authorization mechanism" Collapse section "4.5.1. OAuth 2.0 authorization mechanism" 4.5.1.1. Kafka broker custom authorizer 4.5.2. Configuring OAuth 2.0 authorization support 5. Using AMQ Streams Operators Expand section "5. Using AMQ Streams Operators" Collapse section "5. Using AMQ Streams Operators" 5.1. Using the Cluster Operator Expand section "5.1. Using the Cluster Operator" Collapse section "5.1. Using the Cluster Operator" 5.1.1. Cluster Operator configuration Expand section "5.1.1. Cluster Operator configuration" Collapse section "5.1.1. Cluster Operator configuration" 5.1.1.1. Logging configuration by ConfigMap 5.1.1.2. Restricting Cluster Operator access with network policy 5.1.1.3. Periodic reconciliation 5.1.2. Provisioning Role-Based Access Control (RBAC) Expand section "5.1.2. Provisioning Role-Based Access Control (RBAC)" Collapse section "5.1.2. Provisioning Role-Based Access Control (RBAC)" 5.1.2.1. Delegated privileges 5.1.2.2. ServiceAccount 5.1.2.3. ClusterRoles 5.1.2.4. ClusterRoleBindings 5.2. Using the Topic Operator Expand section "5.2. Using the Topic Operator" Collapse section "5.2. Using the Topic Operator" 5.2.1. Kafka topic resource Expand section "5.2.1. Kafka topic resource" Collapse section "5.2.1. Kafka topic resource" 5.2.1.1. Identifying a Kafka cluster for topic handling 5.2.1.2. Kafka topic usage recommendations 5.2.1.3. Kafka topic naming conventions 5.2.2. Topic Operator topic store Expand section "5.2.2. Topic Operator topic store" Collapse section "5.2.2. Topic Operator topic store" 5.2.2.1. Internal topic store topics 5.2.2.2. Migrating topic metadata from ZooKeeper 5.2.2.3. Downgrading to an AMQ Streams version that uses ZooKeeper to store topic metadata 5.2.2.4. Topic Operator topic replication and scaling 5.2.2.5. Handling changes to topics 5.2.3. Configuring a Kafka topic 5.2.4. Configuring the Topic Operator with resource requests and limits 5.3. Using the User Operator Expand section "5.3. Using the User Operator" Collapse section "5.3. Using the User Operator" 5.3.1. Configuring the User Operator with resource requests and limits 5.4. Monitoring operators using Prometheus metrics 6. Kafka Bridge Expand section "6. Kafka Bridge" Collapse section "6. Kafka Bridge" 6.1. Kafka Bridge overview Expand section "6.1. Kafka Bridge overview" Collapse section "6.1. Kafka Bridge overview" 6.1.1. Kafka Bridge interface Expand section "6.1.1. Kafka Bridge interface" Collapse section "6.1.1. Kafka Bridge interface" 6.1.1.1. HTTP requests 6.1.2. Supported clients for the Kafka Bridge 6.1.3. Securing the Kafka Bridge 6.1.4. Accessing the Kafka Bridge outside of OpenShift 6.1.5. Requests to the Kafka Bridge Expand section "6.1.5. Requests to the Kafka Bridge" Collapse section "6.1.5. Requests to the Kafka Bridge" 6.1.5.1. Content Type headers 6.1.5.2. Embedded data format 6.1.5.3. Message format 6.1.5.4. Accept headers 6.1.6. CORS Expand section "6.1.6. CORS" Collapse section "6.1.6. CORS" 6.1.6.1. Simple request 6.1.6.2. Preflighted request 6.1.7. Kafka Bridge API resources 6.1.8. Kafka Bridge deployment 6.2. Kafka Bridge quickstart Expand section "6.2. Kafka Bridge quickstart" Collapse section "6.2. Kafka Bridge quickstart" 6.2.1. Deploying the Kafka Bridge to your OpenShift cluster 6.2.2. Exposing the Kafka Bridge service to your local machine 6.2.3. Producing messages to topics and partitions 6.2.4. Creating a Kafka Bridge consumer 6.2.5. Subscribing a Kafka Bridge consumer to topics 6.2.6. Retrieving the latest messages from a Kafka Bridge consumer 6.2.7. Commiting offsets to the log 6.2.8. Seeking to offsets for a partition 6.2.9. Deleting a Kafka Bridge consumer 7. Using the Kafka Bridge with 3scale Expand section "7. Using the Kafka Bridge with 3scale" Collapse section "7. Using the Kafka Bridge with 3scale" 7.1. Using the Kafka Bridge with 3scale Expand section "7.1. Using the Kafka Bridge with 3scale" Collapse section "7.1. Using the Kafka Bridge with 3scale" 7.1.1. Kafka Bridge service discovery 7.1.2. 3scale APIcast gateway policies 7.1.3. TLS validation 7.1.4. 3scale documentation 7.2. Deploying 3scale for the Kafka Bridge 8. Cruise Control for cluster rebalancing Expand section "8. Cruise Control for cluster rebalancing" Collapse section "8. Cruise Control for cluster rebalancing" 8.1. Why use Cruise Control? 8.2. Optimization goals overview 8.3. Optimization proposals overview 8.4. Rebalance performance tuning overview 8.5. Cruise Control configuration 8.6. Deploying Cruise Control 8.7. Generating optimization proposals 8.8. Approving an optimization proposal 8.9. Stopping a cluster rebalance 8.10. Fixing problems with a KafkaRebalance resource 9. Validating schemas with Service Registry 10. Distributed tracing Expand section "10. Distributed tracing" Collapse section "10. Distributed tracing" 10.1. Overview of OpenTracing and Jaeger 10.2. Setting up tracing for Kafka clients Expand section "10.2. Setting up tracing for Kafka clients" Collapse section "10.2. Setting up tracing for Kafka clients" 10.2.1. Initializing a Jaeger tracer for Kafka clients 10.2.2. Environment variables for tracing 10.3. Instrumenting Kafka clients with tracers Expand section "10.3. Instrumenting Kafka clients with tracers" Collapse section "10.3. Instrumenting Kafka clients with tracers" 10.3.1. Instrumenting producers and consumers for tracing Expand section "10.3.1. Instrumenting producers and consumers for tracing" Collapse section "10.3.1. Instrumenting producers and consumers for tracing" 10.3.1.1. Custom span names in a Decorator pattern 10.3.1.2. Built-in span names 10.3.2. Instrumenting Kafka Streams applications for tracing 10.4. Setting up tracing for MirrorMaker, Kafka Connect, and the Kafka Bridge Expand section "10.4. Setting up tracing for MirrorMaker, Kafka Connect, and the Kafka Bridge" Collapse section "10.4. Setting up tracing for MirrorMaker, Kafka Connect, and the Kafka Bridge" 10.4.1. Enabling tracing in MirrorMaker, Kafka Connect, and Kafka Bridge resources 11. Managing TLS certificates Expand section "11. Managing TLS certificates" Collapse section "11. Managing TLS certificates" 11.1. Certificate Authorities Expand section "11.1. Certificate Authorities" Collapse section "11.1. Certificate Authorities" 11.1.1. CA certificates 11.1.2. Installing your own CA certificates 11.2. Secrets Expand section "11.2. Secrets" Collapse section "11.2. Secrets" 11.2.1. PKCS #12 storage 11.2.2. Cluster CA Secrets 11.2.3. Client CA Secrets 11.2.4. Adding labels and annotations to Secrets 11.2.5. Disabling ownerReference in the CA Secrets 11.2.6. User Secrets 11.3. Certificate renewal and validity periods Expand section "11.3. Certificate renewal and validity periods" Collapse section "11.3. Certificate renewal and validity periods" 11.3.1. Renewal process with automatically generated CA certificates 11.3.2. Client certificate renewal 11.3.3. Manually renewing the CA certificates generated by the Cluster Operator 11.3.4. Replacing private keys used by the CA certificates generated by the Cluster Operator 11.3.5. Renewing your own CA certificates 11.4. TLS connections Expand section "11.4. TLS connections" Collapse section "11.4. TLS connections" 11.4.1. ZooKeeper communication 11.4.2. Kafka interbroker communication 11.4.3. Topic and User Operators 11.4.4. Cruise Control 11.4.5. Kafka Client connections 11.5. Configuring internal clients to trust the cluster CA 11.6. Configuring external clients to trust the cluster CA 11.7. Kafka listener certificates Expand section "11.7. Kafka listener certificates" Collapse section "11.7. Kafka listener certificates" 11.7.1. Providing your own Kafka listener certificates 11.7.2. Alternative subjects in server certificates for Kafka listeners Expand section "11.7.2. Alternative subjects in server certificates for Kafka listeners" Collapse section "11.7.2. Alternative subjects in server certificates for Kafka listeners" 11.7.2.1. TLS listener SAN examples 11.7.2.2. External listener SAN examples 12. Managing AMQ Streams Expand section "12. Managing AMQ Streams" Collapse section "12. Managing AMQ Streams" 12.1. Working with custom resources Expand section "12.1. Working with custom resources" Collapse section "12.1. Working with custom resources" 12.1.1. Performing oc operations on custom resources Expand section "12.1.1. Performing oc operations on custom resources" Collapse section "12.1.1. Performing oc operations on custom resources" 12.1.1.1. Resource categories 12.1.1.2. Querying the status of sub-resources 12.1.2. AMQ Streams custom resource status information 12.1.3. Finding the status of a custom resource 12.2. Pausing reconciliation of custom resources 12.3. Manually starting rolling updates of Kafka and ZooKeeper clusters Expand section "12.3. Manually starting rolling updates of Kafka and ZooKeeper clusters" Collapse section "12.3. Manually starting rolling updates of Kafka and ZooKeeper clusters" 12.3.1. Prerequisites 12.3.2. Performing a rolling update using a StatefulSet annotation 12.3.3. Performing a rolling update using a Pod annotation 12.4. Discovering services using labels and annotations Expand section "12.4. Discovering services using labels and annotations" Collapse section "12.4. Discovering services using labels and annotations" 12.4.1. Returning connection details on services 12.5. Recovering a cluster from persistent volumes Expand section "12.5. Recovering a cluster from persistent volumes" Collapse section "12.5. Recovering a cluster from persistent volumes" 12.5.1. Recovery from namespace deletion 12.5.2. Recovery from loss of an OpenShift cluster 12.5.3. Recovering a deleted cluster from persistent volumes 12.6. Tuning client configuration Expand section "12.6. Tuning client configuration" Collapse section "12.6. Tuning client configuration" 12.6.1. Kafka producer configuration tuning Expand section "12.6.1. Kafka producer configuration tuning" Collapse section "12.6.1. Kafka producer configuration tuning" 12.6.1.1. Basic producer configuration 12.6.1.2. Data durability 12.6.1.3. Ordered delivery 12.6.1.4. Reliability guarantees 12.6.1.5. Optimizing throughput and latency 12.6.2. Kafka consumer configuration tuning Expand section "12.6.2. Kafka consumer configuration tuning" Collapse section "12.6.2. Kafka consumer configuration tuning" 12.6.2.1. Basic consumer configuration 12.6.2.2. Scaling data consumption using consumer groups 12.6.2.3. Message ordering guarantees 12.6.2.4. Optimizing throughput and latency 12.6.2.5. Avoiding data loss or duplication when committing offsets Expand section "12.6.2.5. Avoiding data loss or duplication when committing offsets" Collapse section "12.6.2.5. Avoiding data loss or duplication when committing offsets" 12.6.2.5.1. Controlling transactional messages 12.6.2.6. Recovering from failure to avoid data loss 12.6.2.7. Managing offset policy 12.6.2.8. Minimizing the impact of rebalances 12.7. Uninstalling AMQ Streams 12.8. Frequently asked questions Expand section "12.8. Frequently asked questions" Collapse section "12.8. Frequently asked questions" 12.8.1. Questions related to the Cluster Operator Expand section "12.8.1. Questions related to the Cluster Operator" Collapse section "12.8.1. Questions related to the Cluster Operator" 12.8.1.1. Why do I need cluster administrator privileges to install AMQ Streams? 12.8.1.2. Why does the Cluster Operator need to create ClusterRoleBindings? 12.8.1.3. Can standard OpenShift users create Kafka custom resources? 12.8.1.4. What do the failed to acquire lock warnings in the log mean? 12.8.1.5. Why is hostname verification failing when connecting to NodePorts using TLS? 13. Custom resource API reference Expand section "13. Custom resource API reference" Collapse section "13. Custom resource API reference" 13.1. Common configuration properties Expand section "13.1. Common configuration properties" Collapse section "13.1. Common configuration properties" 13.1.1. replicas 13.1.2. bootstrapServers 13.1.3. ssl 13.1.4. trustedCertificates 13.1.5. resources 13.1.6. image 13.1.7. livenessProbe and readinessProbe healthchecks 13.1.8. metricsConfig 13.1.9. jvmOptions 13.1.10. Garbage collector logging 13.2. Schema properties Expand section "13.2. Schema properties" Collapse section "13.2. Schema properties" 13.2.1. Kafka schema reference 13.2.2. KafkaSpec schema reference 13.2.3. KafkaClusterSpec schema reference Expand section "13.2.3. KafkaClusterSpec schema reference" Collapse section "13.2.3. KafkaClusterSpec schema reference" 13.2.3.1. listeners 13.2.3.2. config 13.2.3.3. brokerRackInitImage 13.2.3.4. logging 13.2.3.5. KafkaClusterSpec schema properties 13.2.4. GenericKafkaListener schema reference Expand section "13.2.4. GenericKafkaListener schema reference" Collapse section "13.2.4. GenericKafkaListener schema reference" 13.2.4.1. listeners 13.2.4.2. type 13.2.4.3. port 13.2.4.4. tls 13.2.4.5. authentication 13.2.4.6. networkPolicyPeers 13.2.4.7. GenericKafkaListener schema properties 13.2.5. KafkaListenerAuthenticationTls schema reference 13.2.6. KafkaListenerAuthenticationScramSha512 schema reference 13.2.7. KafkaListenerAuthenticationOAuth schema reference 13.2.8. GenericSecretSource schema reference 13.2.9. CertSecretSource schema reference 13.2.10. GenericKafkaListenerConfiguration schema reference Expand section "13.2.10. GenericKafkaListenerConfiguration schema reference" Collapse section "13.2.10. GenericKafkaListenerConfiguration schema reference" 13.2.10.1. brokerCertChainAndKey 13.2.10.2. externalTrafficPolicy 13.2.10.3. loadBalancerSourceRanges 13.2.10.4. class 13.2.10.5. preferredNodePortAddressType 13.2.10.6. useServiceDnsDomain 13.2.10.7. GenericKafkaListenerConfiguration schema properties 13.2.11. CertAndKeySecretSource schema reference 13.2.12. GenericKafkaListenerConfigurationBootstrap schema reference Expand section "13.2.12. GenericKafkaListenerConfigurationBootstrap schema reference" Collapse section "13.2.12. GenericKafkaListenerConfigurationBootstrap schema reference" 13.2.12.1. alternativeNames 13.2.12.2. host 13.2.12.3. nodePort 13.2.12.4. loadBalancerIP 13.2.12.5. annotations 13.2.12.6. GenericKafkaListenerConfigurationBootstrap schema properties 13.2.13. GenericKafkaListenerConfigurationBroker schema reference Expand section "13.2.13. GenericKafkaListenerConfigurationBroker schema reference" Collapse section "13.2.13. GenericKafkaListenerConfigurationBroker schema reference" 13.2.13.1. GenericKafkaListenerConfigurationBroker schema properties 13.2.14. KafkaListeners schema reference 13.2.15. KafkaListenerPlain schema reference 13.2.16. KafkaListenerTls schema reference 13.2.17. TlsListenerConfiguration schema reference 13.2.18. KafkaListenerExternalRoute schema reference 13.2.19. RouteListenerOverride schema reference 13.2.20. RouteListenerBootstrapOverride schema reference 13.2.21. RouteListenerBrokerOverride schema reference 13.2.22. KafkaListenerExternalConfiguration schema reference 13.2.23. KafkaListenerExternalLoadBalancer schema reference 13.2.24. LoadBalancerListenerOverride schema reference 13.2.25. LoadBalancerListenerBootstrapOverride schema reference 13.2.26. LoadBalancerListenerBrokerOverride schema reference 13.2.27. KafkaListenerExternalNodePort schema reference 13.2.28. NodePortListenerOverride schema reference 13.2.29. NodePortListenerBootstrapOverride schema reference 13.2.30. NodePortListenerBrokerOverride schema reference 13.2.31. NodePortListenerConfiguration schema reference 13.2.32. KafkaListenerExternalIngress schema reference 13.2.33. IngressListenerConfiguration schema reference 13.2.34. IngressListenerBootstrapConfiguration schema reference 13.2.35. IngressListenerBrokerConfiguration schema reference 13.2.36. EphemeralStorage schema reference 13.2.37. PersistentClaimStorage schema reference 13.2.38. PersistentClaimStorageOverride schema reference 13.2.39. JbodStorage schema reference 13.2.40. KafkaAuthorizationSimple schema reference Expand section "13.2.40. KafkaAuthorizationSimple schema reference" Collapse section "13.2.40. KafkaAuthorizationSimple schema reference" 13.2.40.1. superUsers 13.2.40.2. KafkaAuthorizationSimple schema properties 13.2.41. KafkaAuthorizationOpa schema reference Expand section "13.2.41. KafkaAuthorizationOpa schema reference" Collapse section "13.2.41. KafkaAuthorizationOpa schema reference" 13.2.41.1. url 13.2.41.2. allowOnError 13.2.41.3. initialCacheCapacity 13.2.41.4. maximumCacheSize 13.2.41.5. expireAfterMs 13.2.41.6. superUsers 13.2.41.7. KafkaAuthorizationOpa schema properties 13.2.42. KafkaAuthorizationKeycloak schema reference 13.2.43. Rack schema reference Expand section "13.2.43. Rack schema reference" Collapse section "13.2.43. Rack schema reference" 13.2.43.1. Rack schema properties 13.2.44. Probe schema reference 13.2.45. JvmOptions schema reference 13.2.46. SystemProperty schema reference 13.2.47. KafkaJmxOptions schema reference Expand section "13.2.47. KafkaJmxOptions schema reference" Collapse section "13.2.47. KafkaJmxOptions schema reference" 13.2.47.1. KafkaJmxOptions schema properties 13.2.48. KafkaJmxAuthenticationPassword schema reference 13.2.49. JmxPrometheusExporterMetrics schema reference 13.2.50. ExternalConfigurationReference schema reference 13.2.51. InlineLogging schema reference 13.2.52. ExternalLogging schema reference 13.2.53. TlsSidecar schema reference Expand section "13.2.53. TlsSidecar schema reference" Collapse section "13.2.53. TlsSidecar schema reference" 13.2.53.1. TlsSidecar schema properties 13.2.54. KafkaClusterTemplate schema reference 13.2.55. StatefulSetTemplate schema reference 13.2.56. MetadataTemplate schema reference Expand section "13.2.56. MetadataTemplate schema reference" Collapse section "13.2.56. MetadataTemplate schema reference" 13.2.56.1. MetadataTemplate schema properties 13.2.57. PodTemplate schema reference Expand section "13.2.57. PodTemplate schema reference" Collapse section "13.2.57. PodTemplate schema reference" 13.2.57.1. hostAliases 13.2.57.2. PodTemplate schema properties 13.2.58. ResourceTemplate schema reference 13.2.59. ExternalServiceTemplate schema reference Expand section "13.2.59. ExternalServiceTemplate schema reference" Collapse section "13.2.59. ExternalServiceTemplate schema reference" 13.2.59.1. ExternalServiceTemplate schema properties 13.2.60. PodDisruptionBudgetTemplate schema reference Expand section "13.2.60. PodDisruptionBudgetTemplate schema reference" Collapse section "13.2.60. PodDisruptionBudgetTemplate schema reference" 13.2.60.1. PodDisruptionBudgetTemplate schema properties 13.2.61. ContainerTemplate schema reference Expand section "13.2.61. ContainerTemplate schema reference" Collapse section "13.2.61. ContainerTemplate schema reference" 13.2.61.1. ContainerTemplate schema properties 13.2.62. ContainerEnvVar schema reference 13.2.63. ZookeeperClusterSpec schema reference Expand section "13.2.63. ZookeeperClusterSpec schema reference" Collapse section "13.2.63. ZookeeperClusterSpec schema reference" 13.2.63.1. config 13.2.63.2. logging 13.2.63.3. ZookeeperClusterSpec schema properties 13.2.64. ZookeeperClusterTemplate schema reference 13.2.65. TopicOperatorSpec schema reference 13.2.66. EntityOperatorSpec schema reference 13.2.67. EntityTopicOperatorSpec schema reference Expand section "13.2.67. EntityTopicOperatorSpec schema reference" Collapse section "13.2.67. EntityTopicOperatorSpec schema reference" 13.2.67.1. logging 13.2.67.2. EntityTopicOperatorSpec schema properties 13.2.68. EntityUserOperatorSpec schema reference Expand section "13.2.68. EntityUserOperatorSpec schema reference" Collapse section "13.2.68. EntityUserOperatorSpec schema reference" 13.2.68.1. logging 13.2.68.2. EntityUserOperatorSpec schema properties 13.2.69. EntityOperatorTemplate schema reference 13.2.70. CertificateAuthority schema reference 13.2.71. CruiseControlSpec schema reference 13.2.72. CruiseControlTemplate schema reference 13.2.73. BrokerCapacity schema reference 13.2.74. KafkaExporterSpec schema reference 13.2.75. KafkaExporterTemplate schema reference 13.2.76. KafkaStatus schema reference 13.2.77. Condition schema reference 13.2.78. ListenerStatus schema reference 13.2.79. ListenerAddress schema reference 13.2.80. KafkaConnect schema reference 13.2.81. KafkaConnectSpec schema reference Expand section "13.2.81. KafkaConnectSpec schema reference" Collapse section "13.2.81. KafkaConnectSpec schema reference" 13.2.81.1. config 13.2.81.2. logging 13.2.81.3. KafkaConnectSpec schema properties 13.2.82. KafkaConnectTls schema reference Expand section "13.2.82. KafkaConnectTls schema reference" Collapse section "13.2.82. KafkaConnectTls schema reference" 13.2.82.1. trustedCertificates 13.2.82.2. KafkaConnectTls schema properties 13.2.83. KafkaClientAuthenticationTls schema reference Expand section "13.2.83. KafkaClientAuthenticationTls schema reference" Collapse section "13.2.83. KafkaClientAuthenticationTls schema reference" 13.2.83.1. certificateAndKey 13.2.83.2. KafkaClientAuthenticationTls schema properties 13.2.84. KafkaClientAuthenticationScramSha512 schema reference Expand section "13.2.84. KafkaClientAuthenticationScramSha512 schema reference" Collapse section "13.2.84. KafkaClientAuthenticationScramSha512 schema reference" 13.2.84.1. username 13.2.84.2. passwordSecret 13.2.84.3. KafkaClientAuthenticationScramSha512 schema properties 13.2.85. PasswordSecretSource schema reference 13.2.86. KafkaClientAuthenticationPlain schema reference Expand section "13.2.86. KafkaClientAuthenticationPlain schema reference" Collapse section "13.2.86. KafkaClientAuthenticationPlain schema reference" 13.2.86.1. username 13.2.86.2. passwordSecret 13.2.86.3. KafkaClientAuthenticationPlain schema properties 13.2.87. KafkaClientAuthenticationOAuth schema reference Expand section "13.2.87. KafkaClientAuthenticationOAuth schema reference" Collapse section "13.2.87. KafkaClientAuthenticationOAuth schema reference" 13.2.87.1. KafkaClientAuthenticationOAuth schema properties 13.2.88. JaegerTracing schema reference 13.2.89. KafkaConnectTemplate schema reference 13.2.90. DeploymentTemplate schema reference 13.2.91. ExternalConfiguration schema reference Expand section "13.2.91. ExternalConfiguration schema reference" Collapse section "13.2.91. ExternalConfiguration schema reference" 13.2.91.1. env 13.2.91.2. volumes 13.2.91.3. ExternalConfiguration schema properties 13.2.92. ExternalConfigurationEnv schema reference 13.2.93. ExternalConfigurationEnvVarSource schema reference 13.2.94. ExternalConfigurationVolumeSource schema reference 13.2.95. Build schema reference Expand section "13.2.95. Build schema reference" Collapse section "13.2.95. Build schema reference" 13.2.95.1. output 13.2.95.2. plugins 13.2.95.3. Build schema properties 13.2.96. DockerOutput schema reference 13.2.97. ImageStreamOutput schema reference 13.2.98. Plugin schema reference 13.2.99. JarArtifact schema reference 13.2.100. TgzArtifact schema reference 13.2.101. ZipArtifact schema reference 13.2.102. KafkaConnectStatus schema reference 13.2.103. ConnectorPlugin schema reference 13.2.104. KafkaConnectS2I schema reference 13.2.105. KafkaConnectS2ISpec schema reference Expand section "13.2.105. KafkaConnectS2ISpec schema reference" Collapse section "13.2.105. KafkaConnectS2ISpec schema reference" 13.2.105.1. KafkaConnectS2ISpec schema properties 13.2.106. KafkaConnectS2IStatus schema reference 13.2.107. KafkaTopic schema reference 13.2.108. KafkaTopicSpec schema reference 13.2.109. KafkaTopicStatus schema reference 13.2.110. KafkaUser schema reference 13.2.111. KafkaUserSpec schema reference 13.2.112. KafkaUserTlsClientAuthentication schema reference 13.2.113. KafkaUserScramSha512ClientAuthentication schema reference 13.2.114. KafkaUserAuthorizationSimple schema reference 13.2.115. AclRule schema reference Expand section "13.2.115. AclRule schema reference" Collapse section "13.2.115. AclRule schema reference" 13.2.115.1. resource 13.2.115.2. type 13.2.115.3. operation 13.2.115.4. host 13.2.115.5. AclRule schema properties 13.2.116. AclRuleTopicResource schema reference 13.2.117. AclRuleGroupResource schema reference 13.2.118. AclRuleClusterResource schema reference 13.2.119. AclRuleTransactionalIdResource schema reference 13.2.120. KafkaUserQuotas schema reference Expand section "13.2.120. KafkaUserQuotas schema reference" Collapse section "13.2.120. KafkaUserQuotas schema reference" 13.2.120.1. quotas 13.2.120.2. KafkaUserQuotas schema properties 13.2.121. KafkaUserTemplate schema reference Expand section "13.2.121. KafkaUserTemplate schema reference" Collapse section "13.2.121. KafkaUserTemplate schema reference" 13.2.121.1. KafkaUserTemplate schema properties 13.2.122. KafkaUserStatus schema reference 13.2.123. KafkaMirrorMaker schema reference 13.2.124. KafkaMirrorMakerSpec schema reference Expand section "13.2.124. KafkaMirrorMakerSpec schema reference" Collapse section "13.2.124. KafkaMirrorMakerSpec schema reference" 13.2.124.1. whitelist 13.2.124.2. KafkaMirrorMakerConsumerSpec and KafkaMirrorMakerProducerSpec 13.2.124.3. logging 13.2.124.4. KafkaMirrorMakerSpec schema properties 13.2.125. KafkaMirrorMakerConsumerSpec schema reference Expand section "13.2.125. KafkaMirrorMakerConsumerSpec schema reference" Collapse section "13.2.125. KafkaMirrorMakerConsumerSpec schema reference" 13.2.125.1. numStreams 13.2.125.2. offsetCommitInterval 13.2.125.3. config 13.2.125.4. groupId 13.2.125.5. KafkaMirrorMakerConsumerSpec schema properties 13.2.126. KafkaMirrorMakerTls schema reference Expand section "13.2.126. KafkaMirrorMakerTls schema reference" Collapse section "13.2.126. KafkaMirrorMakerTls schema reference" 13.2.126.1. trustedCertificates 13.2.126.2. KafkaMirrorMakerTls schema properties 13.2.127. KafkaMirrorMakerProducerSpec schema reference Expand section "13.2.127. KafkaMirrorMakerProducerSpec schema reference" Collapse section "13.2.127. KafkaMirrorMakerProducerSpec schema reference" 13.2.127.1. abortOnSendFailure 13.2.127.2. config 13.2.127.3. KafkaMirrorMakerProducerSpec schema properties 13.2.128. KafkaMirrorMakerTemplate schema reference 13.2.129. KafkaMirrorMakerStatus schema reference 13.2.130. KafkaBridge schema reference 13.2.131. KafkaBridgeSpec schema reference Expand section "13.2.131. KafkaBridgeSpec schema reference" Collapse section "13.2.131. KafkaBridgeSpec schema reference" 13.2.131.1. logging 13.2.131.2. KafkaBridgeSpec schema properties 13.2.132. KafkaBridgeTls schema reference 13.2.133. KafkaBridgeHttpConfig schema reference Expand section "13.2.133. KafkaBridgeHttpConfig schema reference" Collapse section "13.2.133. KafkaBridgeHttpConfig schema reference" 13.2.133.1. cors 13.2.133.2. KafkaBridgeHttpConfig schema properties 13.2.134. KafkaBridgeHttpCors schema reference 13.2.135. KafkaBridgeConsumerSpec schema reference Expand section "13.2.135. KafkaBridgeConsumerSpec schema reference" Collapse section "13.2.135. KafkaBridgeConsumerSpec schema reference" 13.2.135.1. KafkaBridgeConsumerSpec schema properties 13.2.136. KafkaBridgeProducerSpec schema reference Expand section "13.2.136. KafkaBridgeProducerSpec schema reference" Collapse section "13.2.136. KafkaBridgeProducerSpec schema reference" 13.2.136.1. KafkaBridgeProducerSpec schema properties 13.2.137. KafkaBridgeTemplate schema reference 13.2.138. KafkaBridgeStatus schema reference 13.2.139. KafkaConnector schema reference 13.2.140. KafkaConnectorSpec schema reference 13.2.141. KafkaConnectorStatus schema reference 13.2.142. KafkaMirrorMaker2 schema reference 13.2.143. KafkaMirrorMaker2Spec schema reference 13.2.144. KafkaMirrorMaker2ClusterSpec schema reference Expand section "13.2.144. KafkaMirrorMaker2ClusterSpec schema reference" Collapse section "13.2.144. KafkaMirrorMaker2ClusterSpec schema reference" 13.2.144.1. config 13.2.144.2. KafkaMirrorMaker2ClusterSpec schema properties 13.2.145. KafkaMirrorMaker2Tls schema reference 13.2.146. KafkaMirrorMaker2MirrorSpec schema reference 13.2.147. KafkaMirrorMaker2ConnectorSpec schema reference 13.2.148. KafkaMirrorMaker2Status schema reference 13.2.149. KafkaRebalance schema reference 13.2.150. KafkaRebalanceSpec schema reference 13.2.151. KafkaRebalanceStatus schema reference A. Using your subscription Legal Notice Settings Close Language: 日本語 English Language: 日本語 English Format: Multi-page Single-page PDF Format: Multi-page Single-page PDF Language and Page Formatting Options Language: 日本語 English Language: 日本語 English Format: Multi-page Single-page PDF Format: Multi-page Single-page PDF Using AMQ Streams on OpenShift Red Hat AMQ 2021.q2For use with AMQ Streams 1.7 on OpenShift Container PlatformLegal NoticeAbstract This guide describes how to install, configure, and manage Red Hat AMQ Streams to build a large-scale messaging network. Next