Kafka集群安装

Posted koudaiyoutang

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Kafka集群安装相关的知识,希望对你有一定的参考价值。

解压文件到安装目录

tar -zxvf kafka_2.10-0.10.2.1.tgz

1.进入目录

cd kafka_2.10-0.10.2.1

mkdir logs

cd config

cp server.properties server.properties.20190124

2.修改配置

server.properties

broker.id=0

log.dirs=/opt/deploy/kafka_2.10-0.10.2.1/logs

zookeeper.connect=ip:端口,ip:端口,ip:端口

host.name=ip

message.max.byte=5242880

default.replication.factor=2

replica.fetch.max.bytes=5242880

delete.topic.enable=true

开启防火墙(每一台机器都需要开通)

firewall-cmd --add-port=9092/tcp --permanent

firewall-cmd --reload

copy到其他服务器上:

scp -r /opt/deploy/kafka_2.10-0.10.2.1 [email protected]:/opt/deploy/

scp -r /opt/deploy/kafka_2.10-0.10.2.1 [email protected]:/opt/deploy/

修改其他机器的server.properties:

host1改

broker.id=1

host2改

broker.id=2

3.启动

./bin/kafka-server-start.sh -daemon config/server.properties &

创建主题:

./kafka-topics.sh --create --zookeeper ip:端口 --replication-factor 2 --partitions 3 --topic ttest

查看主题:

./kafka-topics.sh --describe --zookeeper ip:端口 --topic ttest

开启生产者:

./kafka-console-producer.sh --broker-list ip:端口,ip:端口,ip:端口 --topic ttest

开启消费者:

./kafka-console-consumer.sh --zookeeper ip:端口 --topic ttest --from-beginning

以上是关于Kafka集群安装的主要内容,如果未能解决你的问题,请参考以下文章

kafka集群安装

kafka集群安装

Kafka基础——集群搭建

大数据高可用集群环境安装与配置(10)——安装Kafka高可用集群

Linux安装kafka集群

安装Kafka集群