Kafka-manager部署与使用简单介绍( 二 ) _Kafka-manager

文章插图

如下图所示
然后启动zookeeper和kafka
zkServer.sh startkafka-server-start.sh -daemon /opt/kafka/config/server.properties

文章插图

3、上传kafka-manager安装包并修改参数

unzip kafka-manager-1.3.3.23.zipmv kafka-manager-1.3.3.23 kafka-managercd kafka-manager/confcp Application.conf application.conf_default_bak

文章插图

修改如下参数 vi application.conf
1)、将kafka-manager.zkhosts="kafka-manager-zookeeper:2181"修改为当前的zookeeper地址与端口
【Kafka-manager部署与使用简单介绍】2)、开启用户名密码验证
basicAuthentication.enabled=false改为 basicAuthentication.enabled=true

文章插图

4、启动kafka-managercd /opt/kafka-manager/bin ./kafka-manager -Dconfig.file=/opt/kafka-manager/conf/application.conf -Dhttp.port=9000

文章插图

5、添加集群，并查看集群的相关信息

kafka-topics.sh --create --zookeeper localhost:2181 --partitions 2 --replication-factor 1 --topic yuanfan_kafka_testkafka-console-producer.sh --bootstrap-server 192.168.31.80:9092 --topic yuanfan_kafka_testkafka-console-consumer.sh --bootstrap-server 192.168.31.80:9092 --topic yuanfan_kafka_test

1)可以创建主题，测试主题的自生产与自消费