在 Debian 上“设 Kafka 参数”通常分三类:服务启动参数、Broker 配置文件参数、命令行/客户端参数。下面按常见使用场景说明。
Kafka 的主配置文件一般在:
/etc/kafka/server.properties
(如果你是用 apt 安装的 Confluent 或 Apache Kafka 包;如果是官方 tar 包,则在 config/server.properties)
# 唯一 ID
broker.id=0
# 监听地址
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://your-host:9092
# Zookeeper(Kafka < 3.0 或仍用 ZK)
zookeeper.connect=localhost:2181
# Kafka 3.x KRaft 模式
# process.roles=broker,controller
# controller.quorum.voters=0@localhost:9093
# 日志
log.dirs=/var/lib/kafka/logs
num.partitions=3
default.replication.factor=1
# 性能相关
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
改完重启:
systemctl restart kafka
如果是 systemd 安装:
/etc/default/kafka
# 或
/etc/kafka/kafka-server-start.properties
设置 JVM 堆内存:
KAFKA_HEAP_OPTS="-Xms1G -Xmx2G"
或直接在启动脚本:
export KAFKA_HEAP_OPTS="-Xms2G -Xmx4G"
kafka-console-producer.sh \
--bootstrap-server localhost:9092 \
--topic test
kafka-console-consumer.sh \
--bootstrap-server localhost:9092 \
--topic test \
--from-beginning
生产者参数示例:
--producer.config client.properties
client.properties:
acks=all
retries=3
batch.size=16384
查看服务:
systemctl status kafka
编辑:
systemctl edit kafka
例如:
[Service]
Environment="KAFKA_HEAP_OPTS=-Xms2G -Xmx4G"
| 需求 | 参数 |
|---|---|
| 改端口 | listeners |
| 外网访问 | advertised.listeners |
| 改数据目录 | log.dirs |
| 改分区数 | num.partitions |
| 改副本数 | default.replication.factor |
| 改内存 | KAFKA_HEAP_OPTS |
如果你能告诉我:
我可以直接给你一份可复制的配置。