<强>
<>强鲁春利的工作笔记 <>强,谁说程序员不能有文艺范?
<人力资源/>
卡夫卡主要的shell脚本有
[hadoop@nnode kafka0.8.2.1],美元会
总计80
-rwxr-xr-x 1, hadoop hadoop , 943, 2015 - 02年- 27 kafka-console-consumer.sh
-rwxr-xr-x 1, hadoop hadoop , 942, 2015 - 02年- 27 kafka-console-producer.sh
-rwxr-xr-x 1, hadoop hadoop , 870, 2015 - 02年- 27 kafka-consumer-offset-checker.sh
-rwxr-xr-x 1, hadoop hadoop , 946, 2015 - 02年- 27 kafka-consumer-perf-test.sh
-rwxr-xr-x 1, hadoop hadoop , 860, 2015 - 02年- 27 kafka-mirror-maker.sh
-rwxr-xr-x 1, hadoop hadoop , 884, 2015 - 02年- 27 kafka-preferred-replica-election.sh
-rwxr-xr-x 1, hadoop hadoop , 946, 2015 - 02年- 27 kafka-producer-perf-test.sh
-rwxr-xr-x 1, hadoop hadoop , 872, 2015 - 02年- 27 kafka-reassign-partitions.sh
-rwxr-xr-x 1, hadoop hadoop , 866, 2015 - 02年- 27 kafka-replay-log-producer.sh
-rwxr-xr-x 1, hadoop hadoop , 872, 2015 - 02年- 27 kafka-replica-verification.sh
-rwxr-xr-x 1, hadoop hadoop 4185年,2015 - 02年- 27 kafka-run-class.sh
-rwxr-xr-x 1, hadoop hadoop 1333年,2015 - 02年- 27 kafka-server-start.sh
-rwxr-xr-x 1, hadoop hadoop , 891, 2015 - 02年- 27 kafka-server-stop.sh
-rwxr-xr-x 1, hadoop hadoop , 868, 2015 - 02年- 27 kafka-simple-consumer-shell.sh
-rwxr-xr-x 1, hadoop hadoop , 861, 2015 - 02年- 27 kafka-topics.sh
drwxr-xr-x 2, hadoop hadoop 4096年,2015 - 02年- 27,窗户
-rwxr-xr-x 1, hadoop hadoop 1370年,2015 - 02年- 27 zookeeper-server-start.sh
-rwxr-xr-x 1, hadoop hadoop , 875, 2015 - 02年- 27 zookeeper-server-stop.sh
-rwxr-xr-x 1, hadoop hadoop , 968, 2015 - 02年- 27 zookeeper-shell.sh
[hadoop@nnode kafka0.8.2.1] $ ,,,,说明:卡夫卡也提供了在windows下运行的蝙蝠脚本,在bin/windows目录下。
管理员脚本
,,,,卡夫卡各组件均依赖于管理员环境,因此在使用卡夫卡之前首先需要具备饲养员环境,可以配置饲养员集群,也可以使用卡夫卡集成的饲养员脚本来启动一个独立模式的动物园管理员节点。
#,启动Zookeeper 服务器
[hadoop@nnode kafka0.8.2.1],美元bin/zookeeper-server-start.sh
用法:bin/zookeeper-server-start.sh zookeeper.properties
#,配置文件路径为配置/zookeeper.properties,主要配置饲养员的本地存储路径(dataDir)
#,内部实现为调用
exec base_dir美元/kafka-run-class.sh
EXTRA_ARGS 美元;org.apache.zookeeper.server.quorum.QuorumPeerMain $ @
#,停止ZooKeeper 服务器
[hadoop@nnode kafka0.8.2.1],美元bin/zookeeper-server-stop.sh
#,内部实现为调用
ps ax |, grep 我;“管理员”,|,grep -v grep |, awk “{print 1美元}”,|,xargs kill 信号情报
#,设置服务器参数
[hadoop@nnode kafka0.8.2.1]美元zookeeper-shell.sh
用法:,bin/zookeeper-shell.sh zookeeper_host:端口[/路径],[arg游戏……]
#,内部实现为调用
exec $ (dirname 0美元)/kafka-run-class.sh org.apache.zookeeper.ZooKeeperMain -server “$ @”
#,zookeeper 壳用来查看饲养员的节点信息
[hadoop@nnode kafka0.8.2.1],美元bin/zookeeper-shell.sh nnode: 2181年,dnode1:2181 dnode2:2181/dnode1:2181 Connecting 用nnode: 2181年,dnode2:2181/Welcome 用管理员!
JLine support is 禁用
观察家::
WatchedEvent 状态:SyncConnected 类型:None 路径:null
ls
[hbase, hadoop-ha,管理,,动物园管理员,,消费者,配置,,zk-book,,经纪人,controller_epoch] ,,,说明:.
卡夫卡启动与停止
#,启动Kafka 服务器
[hadoop@nnode kafka0.8.2.1],美元bin/kafka-server-start.sh
用法:,bin/kafka-server-start.sh (守护进程),server.properties
#,内部实现为调用
exec base_dir美元/kafka-run-class.sh EXTRA_ARGS 美元;kafka.Kafka $ @
#,略
[hadoop@nnode kafka0.8.2.1],美元bin/kafka-run-class.sh
#,停止Kafka 服务器
[hadoop@nnode kafka0.8.2.1]美元kafka-server-stop.sh
#,内部实现为调用
ps ax |, grep 我;“卡夫卡\ .Kafka”, |, grep java |, grep -v grep |, awk “{print 1美元}”,|,xargs kill sigterm
