如何将自定义jar包添加到Strimzi KafkaMirrorMaker v1并加载到类路径

解决方案 #

你可以通过以下3种可行方式实现自定义jar包加载，适配你当前使用的Strimzi kafka.strimzi.io/v1beta2版本MirrorMaker v1部署场景：

方式1：构建自定义镜像（最稳定，推荐） #

• 基于Strimzi官方提供的MirrorMaker基础镜像构建新镜像，把你的自定义jar包直接拷贝到类路径下：

# 基础镜像版本要和你当前部署的Strimzi版本保持一致
FROM quay.io/strimzi/kafka:0.39.0-kafka-3.6.1
USER root:root
# 把本地自定义jar拷贝到MirrorMaker的默认类路径目录
COPY your-custom-message-handler.jar /opt/kafka/libs/
USER 1001

• 构建完镜像推送到你的私有镜像仓库后，在KafkaMirrorMaker CR的spec.image字段指定你的自定义镜像地址即可；如果是通过Helm部署，直接在Helm values里配置mirrorMaker.image参数覆盖默认镜像。

方式2：通过init容器动态拉取jar包 #

如果不想单独维护自定义镜像，可以通过CR的template字段配置init容器，在Pod启动前拉取jar包到类路径目录：

• 在KafkaMirrorMaker CR的spec.template.pod下添加init容器配置，init容器内用wget/curl拉取你存放在内部制品仓库的jar包，通过emptyDir卷挂载/opt/kafka/libs目录，主容器会复用该卷的内容，自动把jar加入类路径。
• 对应配置片段示例：

spec:
  template:
    pod:
      volumes:
        - name: custom-libs
          emptyDir: {}
      initContainers:
        - name: pull-custom-jar
          image: busybox:1.36
          command:
            - wget
            - "-O"
            - "/opt/kafka/libs/your-custom-message-handler.jar"
            - "http://你的内部制品地址/your-custom-message-handler.jar"
          volumeMounts:
            - name: custom-libs
              mountPath: /opt/kafka/libs
    containers:
      - name: kafka-mirror-maker
        volumeMounts:
          - name: custom-libs
            mountPath: /opt/kafka/libs

• 如果你用Helm部署，可以直接把上述配置写到Helm values的mirrorMaker.template对应字段下。

方式3：通过JVM参数扩展类路径 #

如果你已经通过其他方式把jar包挂载到Pod的任意目录，也可以通过配置KAFKA_MIRRORMAKER_JVM_OPTS环境变量追加类路径：

spec:
  kafkaMirrorMaker:
    env:
      - name: KAFKA_MIRRORMAKER_JVM_OPTS
        value: "-cp /path/to/your-custom-message-handler.jar"
      - name: KAFKA_MIRRORMAKER_MESSAGE_HANDLER
        value: "你的自定义Handler全限定类名"
      - name: KAFKA_MIRRORMAKER_MESSAGE_HANDLER_ARGS
        value: "自定义参数"

注意：三种方式都要确保你的自定义MessageHandler类的全限定名和KAFKA_MIRRORMAKER_MESSAGE_HANDLER配置的值完全一致，无拼写错误。

内容的提问来源于stack exchange，提问作者Iwan Satria