在Ubuntu上修改Kafka配置文件主要分为以下几个步骤:
找到配置文件的位置:
vi ./kafka_2.13-2.8.0/config/server.properties 这里的kafka_2.13-2.8.0应替换为你实际安装的Kafka版本路径。
修改配置项:
broker.id:默认值为-1,只有大于等于0的时候,才会正常启动。port:设置为当前Kafka的端口,例如9000。host.name:单机可直接用localhost。log.dirs:设置为保存日志的地方,需要新建一个文件夹,例如/home/XXX/kafka_2.13-2.8.0/logs。zookeeper.connect:设置为Zookeeper的连接IP和端口,例如localhost:2181。找到配置文件的位置:
vi ./kafka_2.13-2.8.0/config/zookeeper.properties 修改配置项:
dataDir:设置为Zookeeper数据储存的位置,例如/home/XXX/kafka/zookeeper/data。dataLogDir:设置为Zookeeper日志储存的位置,例如/home/XXX/kafka/zookeeper/logs。clientPort:设置为Zookeeper的端口,例如2181。maxClientCnxns:设置最大的连接数。tickTime:设置为Zookeeper服务器之间或客户端之间维持心跳的时间间隔,例如2000毫秒。initLimit:设置为Zookeeper接受客户端初始化连接时,最长能忍受多少个心跳时间间隔。mkdir /home/XXX/kafka_2.13-2.8.0/logs mkdir /home/XXX/kafka_2.13-2.8.0/zookeeper mkdir /home/XXX/kafka_2.13-2.8.0/zookeeper/data mkdir /home/XXX/kafka_2.13-2.8.0/zookeeper/logs 创建启动脚本:
touch /home/XXX/kafka_2.13-2.8.0/kafka_start.sh chmod +x /home/XXX/kafka_2.13-2.8.0/kafka_start.sh 编写启动脚本内容:
#!/bin/bash # 先启动Zookeeper /home/XXX/kafka_2.13-2.8.0/bin/zookeeper-server-start.sh /home/XXX/kafka_2.13-2.8.0/config/zookeeper.properties & sleep 3 # 后启动Kafka /home/XXX/kafka_2.13-2.8.0/bin/kafka-server-start.sh /home/XXX/kafka_2.13-2.8.0/config/server.properties & 执行启动脚本:
sh /home/XXX/kafka_2.13-2.8.0/kafka_start.sh 创建停止脚本:
touch /home/XXX/kafka_2.13-2.8.0/kafka_stop.sh chmod +x /home/XXX/kafka_2.13-2.8.0/kafka_stop.sh 编写停止脚本内容:
#!/bin/bash /home/XXX/kafka_2.13-2.8.0/bin/kafka-server-stop.sh sleep 3 /home/XXX/kafka_2.13-2.8.0/bin/zookeeper-server-stop.sh 执行停止脚本:
sh /home/XXX/kafka_2.13-2.8.0/kafka_stop.sh ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic MyTopic ./kafka-console-producer.sh --broker-list localhost:9000 --topic MyTopic ./kafka-console-consumer.sh --bootstrap-server localhost:9000 --topic MyTopic --from-beginning 以上步骤涵盖了在Ubuntu上修改Kafka配置文件的基本流程,具体版本可能会有所不同,请根据实际情况进行调整。