freemanliu/kafka

镜像概述

本镜像提供Kafka消息队列服务的部署支持，包含三个版本：Kafka 1.0.0（搭配JDK8）、Kafka 2.1.0/2.1.1（搭配JDK11），基于freemanliu/openjre8或freemanliu/openjre:11.0.2镜像构建，可快速部署Kafka集群。

核心功能

1. 支持多版本Kafka部署，适配不同JDK环境；
2. 通过环境变量配置broker ID、ZooKeeper连接、堆内存等参数；
3. 开启JMX监控支持，便于服务状态跟踪；
4. 提供Kubernetes集群下3节点部署示例，支持持久化存储。

使用场景

适用于需要消息队列的分布式系统场景：

• 日志收集与实时处理；
• 数据流式处理平台；
• 微服务间异步通信；
• 事件驱动架构。

配置说明

关键环境变量：

• BROKER_ID：Kafka broker唯一标识（必填）；
• ZOO_SERVERS：ZooKeeper集群连接地址（格式：zk-0:2181,zk-1:2181）；
• KAFKA_HEAP_OPTS：JVM堆内存参数（如-Xmx512M -Xms512M）；
• JMX_PORT：JMX监控端口（默认9093）；
• KAFKA_JMX_OPTS：JMX监控配置参数。

Kubernetes部署示例

以下为3节点Kafka集群的Kubernetes配置（以kafka1为例）：

yaml
apiVersion: v1
kind: Service
metadata:
  name: kafka1
  namespace: default
  labels:
    app: kafka1
spec:
  ports:
    - port: 9092
      name: kafka1
  clusterIP: None
  selector:
    app: kafka1
---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: kafka1
  namespace: default
spec:
  replicas: 1
  selector:
    matchLabels:
      app: kafka1
  template:
    metadata:
      labels:
        app: kafka1
    spec:
      volumes:
        - name: kafka-data
          hostPath:
            path: /kafka/data
            type: DirectoryOrCreate
      nodeSelector:
        kafka: "1"
      hostNetwork: true
      dnsPolicy: ClusterFirstWithHostNet
      containers:
        - name: kafka1
          image: freemanliu/kafka:2.1.1-jdk11
          imagePullPolicy: Always
          livenessProbe:
            tcpSocket:
              port: 9092
            timeoutSeconds: 2
          readinessProbe:
            tcpSocket:
              port: 9092
            timeoutSeconds: 2
          resources:
            requests:
              memory: 1Gi
            limits:
              memory: 1Gi
          ports:
            - containerPort: 9092
          volumeMounts:
            - mountPath: /kafka/data
              name: kafka-data
          env:
            - name: JMX_PORT
              value: "9093"
            - name: KAFKA_JMX_OPTS
              value: "-Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Djava.rmi.server.hostname=192.168.0.205 -Djava.net.preferIPv4Stack=true"
            - name: BROKER_ID
              value: "1"
            - name: KAFKA_HEAP_OPTS
              value: "-Xmx512M -Xms512M"
            - name: ZOO_SERVERS
              value: "zk-0.zk-hs:2181,zk-1.zk-hs:2181,zk-2.zk-hs:2181,zk-3.zk-hs:2181,zk-4.zk-hs:2181"

（kafka2、kafka3部署需修改name、BROKER_ID、nodeSelector及java.rmi.server.hostname等参数）