最新版本的Kafkakaker服务器部署在Docker服务器上

最新版本的Kafka部署在Docker服务器上。

#xff1的博客地址a;博客TMDOG666。

前提条件。

开始前，请确保您已经安装了以下环境：

1. Docker。

创建目录。

首先，我们需要创建一个目录来存储Kafka的相关数据：

mkdir。-p。/data/deploy/kafkaCluster/kraft。

创建docker-compose.yaml文件。

在你自己的目录下创建一个名字。docker-compose.yaml。文件，添加以下内容：
在root目录下，我创建了kafka_config文件夹。

docker-compose.yaml下：

version。:。"3"services。:。kafka。:。image。:。'bitnami/kafka:latest'user。:。root。     environment。:。-。KAFKA_ENABLE_KRAFT=yes。       -。KAFKA_CFG_PROCESS_ROLES=broker。,controller。       -。KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER。       -。KAFKA_CFG_LISTENERS=PLAINTEXT。:。//。:。9092。,CONTROLLER。:。//。:。9093。-。KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER。:。PLAINTEXT。,PLAINTEXT。:。PLAINTEXT。       -。KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT。:。//ip。:。9092。-。KAFKA_BROKER_ID=1。       -。KAFKA_CFG_NODE_ID=1。       -。KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=1@localhost。:。9093。-。ALLOW_PLAINTEXT_LISTENER=yes。     volumes。:。-。/data/deploy/kafkaCluster/kraft。:。/bitnami/kafka。:。rw。     ports。:。-。"9092:9092"-。"9093:9093"

配置解释。

• version: "3"：指定Docker 版本的Compose文件。
• services。：定义服务󿀌本例为Kafka服务。
• image: 'bitnami/kafka:latest'：使用Bitnami提供的Kafka最新镜像。
• user: root。：容器由root用户操作。
• environment。：设置环境变量󿀌配置Kafka。
  • KAFKA_ENABLE_KRAFT=yes。：使用KRaft模式。
  • KAFKA_CFG_PROCESS_ROLES=broker,controller。：broker和controler是设置Kafka的角色。
  • KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER。：定义controller的监听器名称。
  • KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093。：定义Kafka的监控地址。
  • KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT。：映射安全协议。
  • KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://ip:9092。：设置广告监听地址󿀌请将。ip。用服务器的实际IP地址替换。
  • KAFKA_BROKER_ID=1。：设置Broker ID。
  • KAFKA_CFG_NODE_ID=1。：设置节点ID。
  • KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=1@localhost:9093。：投票者设置控制器选举。
  • ALLOW_PLAINTEXT_LISTENER=yes。：允许PLAINTEXT监控。
• volumes。：将主机目录挂在容器内，持久数据。
  • /data/deploy/kafkaCluster/kraft:/bitnami/kafka:rw。：将主机的。/data/deploy/kafkaCluster/kraft。将目录挂载到容器中。/bitnami/kafka。目录。
• ports。：暴露端口。
  • "9092:9092"：将主机的9092端口映射到容器的9092端口。
  • "9093:9093"：将主机的9093端口映射到容器的9093端口。

Kafka可以通过添加以下配置来指定 仲裁投票人（在控制器集群;Quorum Voters）,目前配置是单机，所以没有配置。

KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=brokerId@host。:。port。,brokerId@host。:。port。,..。

部署Kafka。

在运行docker-compose的目录下，以下命令启动Kafka服务：

docker-compose。up。 -d。

结果如下：：

测试部署。

确认Kafka服务是否成功运行c;可使用以下命令检查容器状态：

docker。ps。

结果如下：：

如果Kafka容器正在运行，你将看到。bitnami/kafka:latest。列表中有镜像容器。

您还可以使用Kafka命令行工具或Kafka客户端测试Kafka服务󿀌例如，使用Kafka自带的生产者和消费者工具发送和接收消息。

这样，我们完成了在Docker服务器上部署最新版本的Kafka的操作。