kafka-zk-安装测试初体验
第一步: 安装
安装工具brew install kafka 会自动安装依赖zookeeper
注：安装配置文件位置 /usr/local/etc/kafka|zookeeper
注：
第二步: 启动
启动 zookeeper
cd /usr/local/Cellar/kafka/0.10.0.1
./bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &
启动kafka服务
./bin/kafka-server-start /usr/local/etc/kafka/server.properties &
注：『&』表示要挂到后台使用
第三步: 测试
1、创建topic
./bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1
2、查看创建的topic
./bin/kafka-topics --list --zookeeper localhost:2181
3、生产数据
./bin/kafka-console-producer --broker-list localhost:9092 --topic test1
4、消费数据
./bin/kafka-console-consumer --zookeeper localhost:2181 --from-beginning --topic test1
或
./bin/kafka-console-consumer --bootstrap-server localhost:2181 --from-beginning --topic golden
Kafka常用命令:
Consumer
##控制台发送消息
./kafka-console-producer.sh --broker-list 集群IP:Port --topic topic名字
./kafka-console-producer.sh --broker-list 集群IP:Port --topic topic名字
##控制台接收消息
./kafka-console-consumer.sh --zookeeper 集群IP:Port --topic topic名字
./kafka-console-consumer.sh --zookeeper 集群IP:Port --topic topic名字
##查看消费者组
./kafka-consumer-groups.sh --zookeeper 集群IP:Port --list
##查看topic详细信息
./kafka-topics.sh --zookeeper 集群 --topic topic名字 --describe
##查出最大的topic:
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list "集群" --topic topic名字 --time -1
##查topic中的信息：
./kafka-simple-consumer-shell.sh
--broker-list "集群" --offset 最大TOPIC --partition 0 --print-offsets
--topic topic名字 | grep 要查Jobid | more
前台启动kafka：
./kafka-server-start.sh ../config/server.properties
后台启动kafka:
nohup bin/kafka-server-start.sh config/server.properties > 1>/dev/null 2>&1 &
nohup bin/kafka-server-start.sh config/server.properties > kafka_server.out &
1. 启动ZK服务: sh bin/zkServer.sh start
2. 查看ZK服务状态:
3. 停止ZK服务: sh bin/zkServer.sh stop
4. 重启ZK服务: sh bin/zkServer.sh restart
nohup java -jar XXX.jar >XXX.log 2>&1 &
最新文章
- warensoft unity3d 更新说明
- There are no resources that can be added or removed from the server
- async 和 await 的进阶
- window.innerWidth、document.body.clientWidth和html的大小的区别
- Android性能优化--Listview优化
- mysql 聚集函数需要注意的问题
- 阅读《RobHess的SIFT源码分析：综述》笔记
- go 初使用
- 7-ajax的同步和异步？
- 查找后去掉EditTextView的焦点
- MLAPP——概率机器学习知识汇总
- Javascript:scrollWidth,clientWidth,offsetWidth的区别（转）
- linux 内核的futex pi-support，即pi-futex使用rt_mutex委托
- SpringBoot整合Redis及Redis工具类撰写
- 去除菜单项的加速键--‘&’符号
- Ajax 长轮询
- Android UiAutomator2.0
- git clone Failed to connect to 127.0.0.1 port 43213: Connection refused
- MySQL安装，库的操作
- Spring-AOP SpringBoot自动配置和启动Spring AOP