Confluent/KRaft

来自Gea-Suan Lin's Wiki
Gslin留言 | 贡献2023年5月31日 (三) 06:36的版本 →‎設定
跳转到导航 跳转到搜索

Confluent/KRaftApache Kafka在2.8之后推出的功能,由Confluent包装的版本,目的是为了取代Apache ZooKeeper的功能。

设定

先把/etc/kafka/kraft/controller.properties复制到/etc/kafka/server.properties下,然后把以下的设定值改成对应的值:

process.roles=controller
node.id=1
controller.quorum.voters=1@kafka-controller-1.example.com:19092,2@kafka-controller-2.example.com:19092,3@kafka-controller-3.example.com:19092
listeners=CONTROLLER://kafka-controller-1.example.com:19092
controller.listener.names=CONTROLLER
listener.security.protocol.map=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL
log.dirs=/opt/kraft-controller-logs

相关条目

外部连结