我正在開發一些自定義主題名稱映射,并從中生成了一個 jar 檔案。
而且,由于我使用MirrorMaker V1,這些變數,也增加了KAFKA_MIRRORMAKER_MESSAGE_HANDLER與KAFKA_MIRRORMAKER_MESSAGE_HANDLER_ARGS該KafkaMirrorMaker YAML檔案中。
但我不知道如何將這個自定義 jar 檔案物理添加到 KafkaMirrorMaker pod 中。我已經檢查了 KafkaMirrorMaker 的 CRD,但還沒有找到任何線索。
那么,有沒有辦法讓 KafkaMirrorMaker 下載一些檔案/工件并將 jar 檔案包含到類路徑中,以便自定義 MessageHandler 可以找到它?
helm install 命令用于部署Mirror Maker。我目前使用的 KafkaMirrorMaker 的 apiVersion:kafka.strimzi.io/v1beta2
uj5u.com熱心網友回復:
根據strimzi標簽,我假設您使用的是 Strimzi 的 Mirror Maker v1?要添加您自己的 JAR,您需要構建一個自定義容器映像。
您可以修改 Strimzi 專案源并從頭開始構建所有內容(您可以將 JAR 作為依賴項添加到`docker-images/kafka/... 中的第 3 方庫中)。但是當您構建整個專案時,這相當復雜。
最簡單的方法是撰寫自己的 Dockerfile 并使用現有的 Strimzi 鏡像作為基礎鏡像。例如:
FROM quay.io/strimzi/kafka:0.26.0-kafka-3.0.0
USER root:root
COPY ./my-jar.jar /opt/kafka/libs/my-jar.jar
USER 1001
您可以構建此 Dockerfile 并將其推送到您自己的 Docker 注冊表(Docker Hub、Quay,無論您使用什么)。您應該確保FROM根據您使用的 Strimzi 版本和您使用的 KAfka 版本使用正確的影像。
一旦你有了它,你必須告訴Strimzi使用這個影像。您可以使用自定義資源中的.spec.image選項來做到這一點KafkaMirrorMaker。或者,您可以更改STRIMZI_KAFKA_MIRROR_MAKER_IMAGESStrimzi Cluster Operator 部署中的環境變數并更新應該在那里使用的影像。
轉載請註明出處,本文鏈接:https://www.uj5u.com/yidong/367693.html
標籤:Kubernetes 阿帕奇卡夫卡 kubernetes-helm apache-kafka-mirrormaker 斯特里姆齐
