Using the Streams for Apache Kafka Console Red Hat Streams for Apache Kafka 2.9 The Streams for Apache Kafka Console supports your deployment of Streams for Apache Kafka.

Commands:
export NAMESPACE=kafka 1 export LISTENER_TYPE=route 2 export CLUSTER_DOMAIN=<domain_name> 3
cat examples/console/resources/kafka/*.yaml | envsubst | kubectl apply -n USD{NAMESPACE} -f -
get pods -n kafka
NAME READY STATUS RESTARTS strimzi-cluster-operator 1/1 Running 0 console-kafka-console-nodepool-0 1/1 Running 0 console-kafka-console-nodepool-1 1/1 Running 0 console-kafka-console-nodepool-2 1/1 Running 0
export NAMESPACE=operator-namespace
cat install/console-operator/olm/*.yaml | envsubst | kubectl apply -n USD{NAMESPACE} -f -
get pods -n operator-namespace
NAME READY STATUS RESTARTS console-operator 1/1 Running 1
export NAMESPACE=operator-namespace
cat install/console-operator/non-olm/console-operator.yaml | envsubst | kubectl apply -n USD{NAMESPACE} -f -
get pods -n operator-namespace
NAME READY STATUS RESTARTS console-operator 1/1 Running 1
apiVersion: console.streamshub.github.com/v1alpha1 kind: Console metadata: name: my-console spec: hostname: my-console.<cluster_domain> 1 kafkaClusters: - name: console-kafka 2 namespace: kafka 3 listener: secure 4 properties: values: [] 5 valuesFrom: [] 6 credentials: kafkaUser: name: console-kafka-user1 7
apply -f examples/console/resources/console/010-Console-example.yaml -n console-namespace
get pods -n console-namespace
NAME READY STATUS RUNNING console-kafka 1/1 1 1
apiVersion: console.streamshub.github.com/v1alpha1 kind: Console metadata: name: my-console spec: hostname: my-console.<cluster_domain> security: oidc: authServerUrl: <OIDC_discovery_URL> 1 clientId: <client_id> 2 clientSecret: 3 valueFrom: secretKeyRef: name: my-oidc-secret key: client-secret subjects: - claim: groups 4 include: 5 - <team_name_1> - <team_name_2> roleNames: 6 - developers - claim: groups include: - <team_name_3> roleNames: - administrators - include: 7 - <user_1> - <user_2> roleNames: - administrators roles: - name: developers rules: - resources: 8 - kafkas - resourceNames: 9 - <dev_cluster_a> - <dev_cluster_b> - privileges: 10 - '*' - name: administrators rules: - resources: - kafkas - privileges: - '*' kafkaClusters: - name: console-kafka namespace: kafka listener: secure credentials: kafkaUser: name: console-kafka-user1
apiVersion: console.streamshub.github.com/v1alpha1 kind: Console metadata: name: my-console spec: hostname: my-console.<cluster_domain> # kafkaClusters: - name: console-kafka namespace: kafka listener: secure credentials: kafkaUser: name: console-kafka-user1 security: roles: - name: developers rules: - resources: - topics - topics/records - consumerGroups - rebalances - privileges: - get - list - name: administrators rules: - resources: - topics - topics/records - consumerGroups - rebalances - nodes/configs - privileges: - get - list - resources: - consumerGroups - rebalances - privileges: - update
apiVersion: console.streamshub.github.com/v1alpha1 kind: Console metadata: name: my-console spec: hostname: my-console.<cluster_domain> # metricsSources: - name: my-ocp-prometheus type: openshift-monitoring kafkaClusters: - name: console-kafka namespace: kafka listener: secure metricsSource: my-ocp-prometheus credentials: kafkaUser: name: console-kafka-user1 #
apiVersion: console.streamshub.github.com/v1alpha1 kind: Console metadata: name: my-console spec: hostname: my-console.<cluster_domain> # metricsSources: - name: my-custom-prometheus type: standalone url: <prometheus_instance_address> 1 authentication: 2 username: my-user password: my-password trustStore: 3 type: JKS content: valueFrom: configMapKeyRef: name: my-prometheus-configmap key: ca.jks password: 4 value: changeit kafkaClusters: - name: console-kafka namespace: kafka listener: secure metricsSource: my-ocp-prometheus credentials: kafkaUser: name: console-kafka-user1 #
dnf install <package_name>
dnf install <path_to_download_package>