Kafka:https://kafka.apache.org/downloads
Kafka ToolsK:
二、kafka安装启动1、将安装包上穿到linux上
2、解压安装包
tar -zxvf kafka_2.13-3.0.0.tgz
3、开放防火墙端口号
firewall-cmd --permanent --zone=public --add-port=2181/tcp
firewall-cmd --permanent --zone=public --add-port=9092/tcp
firewall-cmd --reload
4、启动zookeeper
cd /usr/local/java/kafka_2.13-3.0.0/bin/
./zookeeper-server-start.sh …/config/zookeeper.properties
5、启动kafka
./zookeeper-server-start.sh …/config/zookeeper.properties
6、创建主题
./kafka-topics.sh --bootstrap-server localhost:9092 --create --topic gwz --partitions 2 --replication-factor 1
7、查看主题信息
./kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic gwz
8、控制台启动生产者
./kafka-console-producer.sh --topic gwz --bootstrap-server localhost:9092
9、控制台启动消费者
./kafka-console-consumer.sh --topic gwz --bootstrap-server localhost:9092
三、工具连接
1、修改连接地址
2、可能连上了zookeeper,但是连不上kafka
3、解决方法
本地 hosts 增加个 ip hostname 映射即可解决
路径:C:WindowsSystem32driversetc
地 hosts 增加个 ip hostname 映射即可解决
路径:C:WindowsSystem32driversetc
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)