Login as normal user:
oc login -u user
The Kafka Cluster is described in the event-bus-kafka.yml
file.
You can deploy or update the Kafka cluster with the following command:
oc apply -f ./configmap/
oc apply -f event-bus-kafka.yml
This cluster is available with the following services:
$ oc get svc
NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) AGE
event-bus-kafka-bootstrap ClusterIP 172.30.20.58 <none> 9091/TCP,9092/TCP,9093/TCP 84s
event-bus-kafka-brokers ClusterIP None <none> 9090/TCP,9091/TCP,9092/TCP,9093/TCP 84s
event-bus-zookeeper-client ClusterIP 172.30.119.58 <none> 2181/TCP 3m5s
event-bus-zookeeper-nodes ClusterIP None <none> 2181/TCP,2888/TCP,3888/TCP 3m5s
The event-bus-kafka-bootstrap
service is used to connect the producers and consumers with this cluster.
- Port
9092
: Unsecured port - Port
9093
: Secured port - Port
9404
: Metrics port
We could check the status of this Apache Kafka cluster with:
❯ oc get kafka
NAME DESIRED KAFKA REPLICAS DESIRED ZK REPLICAS READY WARNINGS
event-bus 3 3 True
To describe the Kafka:
oc get kafka event-bus -o yaml
The following pods will be deployed:
❯ oc get pod
NAME READY STATUS RESTARTS AGE
event-bus-entity-operator-5fb8465fd5-s4zs2 3/3 Running 0 55s
event-bus-kafka-0 1/1 Running 0 2m30s
event-bus-kafka-1 1/1 Running 0 2m30s
event-bus-kafka-2 1/1 Running 0 2m30s
event-bus-kafka-exporter-6f7ffb5b8b-dzslg 1/1 Running 0 14s
event-bus-zookeeper-0 1/1 Running 0 4m11s
event-bus-zookeeper-1 1/1 Running 0 4m11s
event-bus-zookeeper-2 1/1 Running 0 4m11s
strimzi-cluster-operator-v0.26.0-747fcdb666-rjf6w 1/1 Running 0 6m7s
References: