0

我正在开发一些自定义主题名称映射，并从中生成了一个 jar 文件。

由于我使用的是 MirrorMaker v1，因此这些变量也已添加KAFKA_MIRRORMAKER_MESSAGE_HANDLER到KAFKA_MIRRORMAKER_MESSAGE_HANDLER_ARGSKafkaMirrorMaker yaml 文件中。

但我不知道如何将此自定义 jar 文件物理添加到 KafkaMirrorMaker pod 中。我已经检查了 KafkaMirrorMaker 的 CRD，但还没有找到任何线索。

那么，有没有办法让 KafkaMirrorMaker 下载一些文件/工件并将 jar 文件包含到类路径中，以便自定义 MessageHandler 可以找到它？

helm install 命令用于部署 Mirror Maker。我目前使用的 KafkaMirrorMaker 的 apiVersion：kafka.strimzi.io/v1beta2

4

1 回答 1

1

根据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_IMAGES在 Strimzi Cluster Operator 部署中更改环境变量并更新应该在那里使用的图像。

于 2021-11-25T11:40:03.930 回答