13518219792
这篇文章将为大家详细讲解有关CentOS7中怎么安装kafka环境，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。
10年积累的网站设计制作、网站设计经验，可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你，你也不认识我。但先网站策划后付款的网站建设流程，更有东安免费网站建设让你可以放心的选择与我们合作。
第一步：安装zookeeper环境
1、下载zookeeper包 zookeeper-3.4.5.tar.gz 2、解压至 /usr/local/zookeeper-3.4.5 3、在 /usr/local/zookeeper-3.4.5 创建两个文件夹 #mkdir data #数据文件保存目录 #mkdir logs #日志文件保存目录
4、在conf目录下新增zoo.cfg配置文件 内容如下
# The number of milliseconds of each tick tickTime=2000 # The number of ticks that the initial # synchronization phase can take initLimit=10 # The number of ticks that can pass between # sending a request and getting an acknowledgement syncLimit=5 # the directory where the snapshot is stored. # do not use /tmp for storage, /tmp here is just # example sakes. dataDir=/usr/local/zookeeper-3.4.5/data dataLogDir=/usr/local/zookeeper-3.4.5/logs # the port at which the clients will connect clientPort=2181
5、把zookeeper注册为centos服务
#在/usr/lib/systemd/system 目录下创建zookeeper.service文件 #vim /usr/lib/systemd/system/zookeeper.service [Unit] Description=zookeeper service After=network.target [Service] Type=forking ExecStart=/usr/local/zookeeper-3.4.5/bin/zkServer.sh start ExecReload=/usr/local/zookeeper-3.4.5/bin/zkServer.sh restart ExecStop=/usr/local/zookeeper-3.4.5/bin/zkServer.sh stop PrivateTmp=true [Install] WantedBy=multi-user.target
6、后续在文件/zookeeper/apache-zookeeper-3.5.6-bin/bin/zkEnv.sh开头处插入JAVA环境路径：
JAVA_HOME="/usr/java/jdk1.8.0_231"
二、kafka安装
1、把文件解压到 /usr/local/kafka_2.12-1.0.2
2、修改配置文件/usr/local/kafka_2.12-1.0.2/config/server.properties
broker.id=1 # 唯一ID同一集群下broker.id不能重复 listeners=PLAINTEXT://localhost:9092 # 监听地址 log.dirs=/opt/kafka_2.11-1.0.1/data # 数据目录 log.retention.hours=168 # kafka数据保留时间单位为hour 默认 168小时即 7天 log.retention.bytes=1073741824 #(kafka数据量最大值，超出范围自动清理，和 log.retention.hours配合使用，注意其最大值设定不可超磁盘大小） zookeeper.connect:192.168.8.13:2181 #(zookeeper连接ip及port,多个以逗号分隔)
3、注册kafka为服务
#在/etc/systemd/system 目录下创建kafka.service文件 #vim /etc/systemd/system/kafka.service [Unit] Description=kafka service After=network.target [Service] Type=forking ExecStart=/usr/local/kafka_2.12-1.0.2/bin/kafka-server-start.sh -daemon /usr/local/kafka_2.12-1.0.2/config/server.properties ExecStop=/usr/local/kafka_2.12-1.0.2/bin/kafka-server-stop.sh PrivateTmp=true [Install] WantedBy=multi-user.target
4、设置sasl加密
# 1.新建配置文件
vi ./config/kafka_server_jaas.conf
# 文件内容
# username定义一个公共的用户名，用于节点之间进行通信，user_xxxx主要是客户端用来连接kafka的，等号后面是密码，xxxxx是用户名，这里大小写一个字都不能差，除了用户名和密码
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin-sec"
user_admin="admin-sec"
user_producer="prod-sec"
user_consumer="cons-sec";
};
# 2.修改kafka启动时的配置文件，server.properties
# 我的做法是复制一份
cp ./config/server.properties ./config/server_sasl.properties
# 修改内容如下，在文末添加如下内容：
# 注意点：192.168.8.13是我当前主机ip,9092是kafka通信端口，其他的地方保持一致
listeners=SASL_PLAINTEXT://192.168.8.13:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
allow.everyone.if.no.acl.found=true
# 3.修改启动脚本
vi ./bin/kafka-server-start.sh
# 找到 export KAFKA_HEAP_OPTS
#添加jvm 参数，注意kafka_server_jaas.conf文件是之前第一步创建的安全认证文件
#-Djava.security.auth.login.config=/usr/local/software/kafka/config/kafka_server_jaas.conf
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G -Djava.security.auth.login.config=/usr/local/software/kafka/config/kafka_server_jaas.conf"
fi关于CentOS7中怎么安装kafka环境就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
