debian kafka生产者咋用

debian

小樊

2026-09-03 19:12:11

栏目: 智能运维

在 Debian 上用 Kafka 生产者，一般分三步：装 Kafka → 启动服务 → 用生产者发消息。下面给你一个最实用、能直接跑的流程（以 Kafka 3.x 为例，自带 Zookeeper 的方式）。

一、安装 Kafka（Debian）

sudo apt update
sudo apt install -y default-jdk wget

cd /opt
sudo wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
sudo tar -xzf kafka_2.13-3.7.0.tgz
sudo mv kafka_2.13-3.7.0 kafka

二、启动 Kafka

1️⃣ 启动 Zookeeper

cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties

2️⃣ 启动 Kafka

（新开一个终端）

cd /opt/kafka
bin/kafka-server-start.sh config/server.properties

三、创建 Topic

bin/kafka-topics.sh \
  --create \
  --topic test \
  --bootstrap-server localhost:9092 \
  --partitions 1 \
  --replication-factor 1

查看 topic：

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

四、使用 Kafka 生产者（重点）

✅ 方式 1：命令行生产者（最常用）

bin/kafka-console-producer.sh \
  --topic test \
  --bootstrap-server localhost:9092

然后直接输入消息：

hello kafka
debian kafka test

按 Ctrl+C 退出

✅ 方式 2：带 key 的生产者

bin/kafka-console-producer.sh \
  --topic test \
  --bootstrap-server localhost:9092 \
  --property "parse.key=true" \
  --property "key.separator=:"

输入格式：

user1:hello
user2:world

五、验证消息（消费者）

bin/kafka-console-consumer.sh \
  --topic test \
  --bootstrap-server localhost:9092 \
  --from-beginning

六、用 Python 生产者（Debian 常见）

pip install kafka-python

from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers='localhost:9092')

producer.send('test', b'hello from python')
producer.flush()

七、常见问题

❌ Connection refused

Kafka 没启动
listeners=PLAINTEXT://localhost:9092

❌ Topic 不存在

自动创建关闭时要手动建

auto.create.topics.enable=true

如果你是用 Docker / systemd / 集群 / PHP / Go，告诉我我给你对应版本。