ibmcom/kafka-ppc64le

Apache Kafka Docker镜像文档

镜像概述

该Docker镜像提供Apache Kafka流处理平台，基于ppc64le架构的Linux系统，支持版本0.10.2。可快速搭建单节点Kafka环境，用于开发测试、消息队列及流数据处理场景。

核心功能与特性

• 支持单节点Kafka与Zookeeper部署
• 提供主题创建、列表管理等基础功能
• 支持文件或控制台输入的消息生产
• 提供控制台消息消费及结果验证
• 兼容ppc64le架构的Linux系统

使用场景

• 本地开发环境的Kafka服务快速搭建
• 流数据处理功能验证与测试
• Apache Kafka基础功能学习与演示

使用方法与配置说明

支持的标签

• 0.10.2

运行容器

启动Kafka容器并进入交互式终端：

bash
docker run -it kafka /bin/bash

启动单节点服务器

在容器内执行以下命令启动后台服务：

bash
cd /<source_root>/kafka
# 启动Zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
# 启动Kafka服务器
bin/kafka-server-start.sh -daemon config/server.properties

注意：服务日志位于/<source_root>/kafka/logs/目录，可查看启动状态。

主题管理操作

创建测试主题

创建名为test的单分区、单副本主题：

bash
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

列出所有主题

bash
bin/kafka-topics.sh --list --zookeeper localhost:2181

消息生产与消费

创建消息文件

生成测试消息文件（也可直接通过控制台输入）：

bash
echo -e "Congratulations\nThe build is working\n\nWelcome to Apache Kafka with Linux on ppc64le Systems" > /tmp/msg.log

生产消息到主题

将消息文件内容发送至test主题：

bash
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test < /tmp/msg.log

消费消息并验证

启动消费者从起始位置消费最多4条消息：

bash
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning --max-messages 4

预期输出：

Congratulations
The build is working

Welcome to Apache Kafka with Linux on ppc64le Systems
Consumed 4 messages

交互式消息收发

在两个终端分别执行以下命令可实现实时消息交互：

• 生产者（控制台输入模式）：

  bash
  bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
  

• 消费者（实时接收模式）：

  bash
  bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
  

说明：生产者终端输入的每行内容将实时显示在消费者终端。

多节点集群配置

当前示例为单节点部署，多节点集群配置请参考官方文档：Apache Kafka Documentation