kafka集群安装
2017-05-19 19:33
218 查看
3、在linux中使用wget命令下载安装包
wget http://mirrors.hust.edu.cn/apache/kafka/0.8.2.2/kafka_2.11-0.8.2.2.tgz
4、解压文件并创建软连接
tar -zxvf /export/software/kafka_2.11-0.8.2.2.tgz -C /export/servers/
cd /export/servers/
ln -s kafka_2.11-0.8.2.2 kafka
5、修改配置文件
cp /export/servers/kafka/config/server.properties /export/servers/kafka/config/server.properties.bak
vi /export/servers/kafka/config/server.properties
输入以下内容:
6、将配置好的文件kafka安装文件拷贝到其它机器
scp -r /export/servers/kafka_2.11-0.8.2.2 kafka02:/export/servers
然后分别在各机器上创建软连
cd /export/servers/
ln -s kafka_2.11-0.8.2.2 kafka
7、依次修改各服务器上配置文件的的broker.id,分别是0,1,2不得重复。
8、启动kafka集群
依次在各节点上启动kafka
bin/kafka-server-start.sh config/server.properties
结果如下
8、常用命令
查看当前服务器中的所有topic
bin/kafka-topics.sh --list --zookeeper zk01:2181
创建topic
bin/kafka-topics.sh --create --zookeeper zk01:2181 --replication-factor 1 --partitions 1 --topic test
删除topic
sh bin/kafka-topics.sh --delete --zookeeper zk01:2181 --topic test
删除topic需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。
通过shell命令发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
通过shell消费消息
sh kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic test
查看消费位置
sh kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper zk01:2181 --group testGroup
产看某个Top的详情
sh kafka-topics.sh --topic test --describe --zookeeper zk01:2181
wget http://mirrors.hust.edu.cn/apache/kafka/0.8.2.2/kafka_2.11-0.8.2.2.tgz
4、解压文件并创建软连接
tar -zxvf /export/software/kafka_2.11-0.8.2.2.tgz -C /export/servers/
cd /export/servers/
ln -s kafka_2.11-0.8.2.2 kafka
5、修改配置文件
cp /export/servers/kafka/config/server.properties /export/servers/kafka/config/server.properties.bak
vi /export/servers/kafka/config/server.properties
输入以下内容:
6、将配置好的文件kafka安装文件拷贝到其它机器
scp -r /export/servers/kafka_2.11-0.8.2.2 kafka02:/export/servers
然后分别在各机器上创建软连
cd /export/servers/
ln -s kafka_2.11-0.8.2.2 kafka
7、依次修改各服务器上配置文件的的broker.id,分别是0,1,2不得重复。
8、启动kafka集群
依次在各节点上启动kafka
bin/kafka-server-start.sh config/server.properties
结果如下
8、常用命令
查看当前服务器中的所有topic
bin/kafka-topics.sh --list --zookeeper zk01:2181
创建topic
bin/kafka-topics.sh --create --zookeeper zk01:2181 --replication-factor 1 --partitions 1 --topic test
删除topic
sh bin/kafka-topics.sh --delete --zookeeper zk01:2181 --topic test
删除topic需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。
通过shell命令发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
通过shell消费消息
sh kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic test
查看消费位置
sh kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper zk01:2181 --group testGroup
产看某个Top的详情
sh kafka-topics.sh --topic test --describe --zookeeper zk01:2181
相关文章推荐
- zookeeper+kafka集群安装之一
- zookeeper+kafka集群安装之二
- 在安装过Kafka集群的环境中再次安装Kafka出现的问题
- Kafka 集群的安装与配置
- kafka集群安装与配置
- 分布式消息队列Kafka集群安装
- kafka集群安装配置
- [bigdata] kafka集群安装及测试
- kafka集群安装、配置
- kafka2.9.2的分布式集群安装和demo(java api)测试
- zookeeper+kafka集群安装之二
- Kafka集群安装
- kafka 集群安装与安装测试
- Linux下部署Kafka分布式集群,安装与测试
- Kafka集群安装
- zookeeper+kafka集群安装之一
- Kafka集群安装
- kafka2.9.2的分布式集群安装和demo(java api)测试
- Centos安装Kafka集群
- windows安装kafka的集群配置