[Kafka-connect] Install lenses to manage Kafka.

Như bạn thấy mình đã có những bài nói về comand trong kafka cũng như kafka-connect
Chúng sẽ có 1 UI để quản lý đó là lense, giao diện khá đẹp.

Contents

1) License
- 1.1) It’s free!
  - 1.1.1) Run Kafka lenses on docker.
  - 1.1.2) Install Kafka lenses on Kubernetes.
- 1.2) lenses-enterprise
2) Configurate Lenses that connect to Kafka-connect.

1) License

Để run được lenses chúng ta cần có file là license.json

1.1) It’s free!

chúng ta cần vào trang web này để đăng ký sử dụng lenses

https://lenses.io/downloads/lenses/

sau đó chúng ta sẽ nhận mail:

1.1.1) Run Kafka lenses on docker.

Bạn sẽ run docker như trong mail

docker run -e ADV_HOST=127.0.0.1 \
-e EULA="https://licenses.lenses.io/download/lensesdl?id=7ff368f2-88e9-11ec-9ed6-xxxxxxxxx" \
--rm -p 3030:3030 -p 9092:9092 lensesio/box

Nếu bạn truy cập bằng IP của VM thì thay ADV_HOST=192.168.101.36

Nhưng có 1 điều mình cảm giác đây bạn AIO nó có cả kafka, zookeeper,…
Khá là nhiều components bên trong.
mà mình chỉ cần lense thôi.

Một lưu ý nữa:
là bạn có thể truy cập vào đường link “https://licenses.lenses.io/download/lensesdl?id=7ff368f2-88e9-11ec-9ed6-xxxxxxxxx” trong EULA bạn lấy được file license.json

Lấy các Environment ở đâu?
Tình tìm lanh quanh thì thấy cũng ko có chỉ rõ mình lấy trong link này:
https://docs.lenses.io/4.3/installation/docker/

Mình sẽ không dụng image lensesio/box. Mà mình có lệnh run docker như sau:

docker run -e ADV_HOST=192.168.101.36 \
-e LENSES_KAFKA_BROKERS="PLAINTEXT://192.168.101.36:9092" \
-v /root/kafka-lenses/license.json:/data/license.json  \
--rm -p 9991:9991 lensesio/lenses

Bạn để ý là ở đây mình có khai báo việc kết nối đến Kafka nào và mình có mount file license.json

Mình tưởng ko hết hạn mà vẫn có hết bạn các bạn ạ

truy cập port 9991
với user/pass
admin/admin

1.1.2) Install Kafka lenses on Kubernetes.

Đâu tiên chúng ta cần có helm của lenses.
lấy các value để tham khảo?

helm repo add lensesio https://helm.repo.lenses.io
show values lensesio/lenses > lenses.yaml

Giờ mình cung cấp cho các bạn value.yaml

lenses:
  kafka:
    bootstrapServers:
      - name: 192.168.101.36
        port: 9092
        sslPort: 9093
        saslSslPort: 9094
        saslPlainTextPort: 9095
  license: |-
              {"key": "eyJhbGciOiJBMTQ", "source": "Lenses.io Ltd", "details": "Lenses", "clientId": "7ff368f2-88e9-11ec-9ed6-42010af01003"}

Bạn thấy nó sẽ có phần license và bạn muốn connect đến Kafka với IP nào

1.2) lenses-enterprise

Nếu nhà bạn có điều kiển có thể trial bản enterprise

Mình thấy có bản “lenses-enterprise”

https://lenses.io/downloads/lenses-enterprise/

2) Configurate Lenses that connect to Kafka-connect.

vậy chúng ta cần config kết nối đến kafka connect.

https://docs.lenses.io/4.3/configuration/options/helm/#helm-connect

mình sẽ cung câp thêm value để các bạn update nhé:

lenses:
  connectClusters:
    enabled: true
    clusters:
      - name: datascience
        protocol: http
        port: 8083
        jmxPort: 5556
        offsetsTopic: connect-offsets-datascience
        statusTopic: connect-statuses-datascience
        configTopic: connect-configs-datascience
        hosts:
          - host: kafka-connect-cp-kafka-connect
            metrics:
              type: "JMX"
              port: 5556
              username:
              password:
              ssl:
  kafka:
    bootstrapServers:
      - name: 192.168.101.36
        port: 9092
        sslPort: 9093
        saslSslPort: 9094
        saslPlainTextPort: 9095
  license: |-
              {"key": "eyJhbGcNoNpAP16KCa9Hb-dp7xQ", "source": "Lenses.io Ltd", "details": "Lenses", "clientId": "7ff368f2-88e9-11ec-9ed6-42010af01003"}