day18 : kafka服务应用 on K8S (下)

昨天介绍了kafka的机制，今天将会透过strimzi的方式配置kafka cluster，同样的会介绍用operator的方式进行布署，strimzi可以管理kafka的丛集、user、topic跟bridge连线，那麽就来尝试玩看看吧。

首先创建一个kafka的namespaces

kubectl create ns strimzi
#下载yaml 
wget https://strimzi.io/install/latest?namespace=strimzi
kubectl apply -f yaml -n strimzi

完成crd後就可以创建kafka cluster的instance罗

apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
  name: lab1-kafka
spec:
  kafka:
    version: 2.8.0
    replicas: 1
    listeners:
      - name: plain
        port: 9092
        type: internal
        tls: false
      - name: tls
        port: 9093
        type: internal
        tls: true
    config:
      offsets.topic.replication.factor: 1
      transaction.state.log.replication.factor: 1
      transaction.state.log.min.isr: 1
      log.message.format.version: "2.8"
      inter.broker.protocol.version: "2.8"
    storage:
      type: jbod
      volumes:
      - id: 0
        type: persistent-claim
        size: 20Gi
        deleteClaim: false
    template:
      pod:
        securityContext:
          runAsUser: 0
          fsGroup: 0
  zookeeper:
    replicas: 1
    storage:
      type: persistent-claim
      size: 20Gi
      deleteClaim: false
    template:
      pod:
        securityContext:
          runAsUser: 0
          fsGroup: 0
  entityOperator:
    topicOperator: {}
    userOperator: {}

这样就会建出kafka罗，那就来使用看看吧

kubectl -n strimzi run kafka-producer -ti --image=quay.io/strimzi/kafka:0.25.0-kafka-2.8.0 --rm=true --restart=Never -- bin/kafka-console-producer.sh --broker-list my-cluster-kafka-bootstrap:9092 --topic my-topic

kubectl -n strimzi run kafka-consumer-2 -ti --image=quay.io/strimzi/kafka:0.25.0-kafka-2.8.0 --rm=true --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server my-cluster-kafka-bootstrap:9092 --topic my-topic --from-beginning

看起来没什麽问题呢，那麽要从外部使用kafka的话，strimzi有开发kafka-bridge让外部使用http或是amqp的方式连线进去使用kafka，而topic也可以用crd进行控管。