在 Debian 上修改 Kafka 参数,通常就是修改 Kafka 的配置文件并重启(或动态刷新)相关服务。下面按“常见场景 + 操作步骤”给你说明。
如果你是用 APT / Deb 包 安装的 Kafka(如 confluent 或某些发行版):
/etc/kafka/
├── server.properties
├── producer.properties
├── consumer.properties
如果你是手动下载的 Kafka(官方 tar.gz):
/opt/kafka/config/server.properties
sudo vi /etc/kafka/server.properties
常见修改示例:
# broker 唯一 ID
broker.id=1
# 监听地址
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://your-host:9092
# 日志(数据)目录
log.dirs=/var/lib/kafka/logs
# 分区与副本
num.partitions=3
default.replication.factor=3
# 日志保留
log.retention.hours=168
log.segment.bytes=1073741824
修改后保存。
sudo systemctl restart kafka
查看状态:
sudo systemctl status kafka
查看日志:
journalctl -u kafka -f
/opt/kafka/bin/kafka-server-stop.sh
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
kafka-configs.sh --bootstrap-server localhost:9092 \
--entity-type topics \
--entity-name my-topic \
--alter \
--add-config retention.ms=86400000
kafka-configs.sh --bootstrap-server localhost:9092 \
--entity-type topics \
--entity-name my-topic \
--describe
编辑:
/etc/kafka/producer.properties
/etc/kafka/consumer.properties
或在命令行指定:
kafka-console-producer.sh \
--bootstrap-server localhost:9092 \
--topic test \
--producer.config /etc/kafka/producer.properties
如果是 Deb 安装:
/etc/default/kafka
或:
/etc/kafka/kafka-env.sh
示例:
KAFKA_HEAP_OPTS="-Xms2g -Xmx2g"
修改后重启 Kafka。
sudo chown -R kafka:kafka /var/lib/kafka
listeners 后,客户端必须用 advertised.listenersnum.partitions)只影响新建 Topic我可以给你更精确的修改方式,如果你补充:
例如:
我想改 Kafka 的最大消息大小和副本数
我可以直接给你完整配置示例。