Connecting to Strimzi Kafka Cluster from your Local Machine : CLI & Programatic Access

Karan Singh

·

Follow

2 min read

·

Oct 1, 2021

--

Share

Why you need this ?

• For local development you want to connect to a remote Kafka Cluster running on OpenShift , that is deployed using Strimzi Operator

Prerequisite

• OpenShift Container Platform or OKD
• Strimzi Operator deployed

Deploy Kafka Cluster

• Create a YAML file with these contents (only for dev/test clusters)

apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
  name: my-cluster
  namespace: nestjs-testing
spec:
  entityOperator:
    topicOperator: {}
    userOperator: {}
  kafka:
    config:
      inter.broker.protocol.version: "2.8"
      log.message.format.version: "2.8"
      offsets.topic.replication.factor: 3
      transaction.state.log.min.isr: 2
      transaction.state.log.replication.factor: 3
    listeners:
    - name: plain
      port: 9092
      tls: false
      type: internal
    - name: tls
      port: 9093
      tls: true
      type: internal
    - name: route
      port: 9094
      tls: true
      type: route
    replicas: 3
    storage:
      type: ephemeral
    version: 2.8.0
  zookeeper:
    replicas: 3
    storage:
      type: ephemeral

Preparing to Connect

oc get secret my-cluster-cluster-ca-cert -o jsonpath='{.data.ca\.crt}' | base64 -d > ca.crt