查看“1+X中级A卷:kafka集群”的源代码
←
1+X中级A卷:kafka集群
跳转至:
导航
,
搜索
因为以下原因,您没有权限编辑本页:
您所请求的操作仅限于该用户组的用户使用:
用户
您可以查看与复制此页面的源代码。
第一步 先解压上传的kafka压缩包 [root@zookeeper1 ~]# tar -zxvf kafka_2.11-1.1.1.tgz kafka_2.11-1.1.1/ kafka_2.11-1.1.1/LICENSE kafka_2.11-1.1.1/NOTICE kafka_2.11-1.1.1/bin/ kafka_2.11-1.1.1/bin/kafka-preferred-replica-election.sh kafka_2.11-1.1.1/bin/connect-standalone.sh kafka_2.11-1.1.1/bin/kafka-server-start.sh kafka_2.11-1.1.1/bin/windows/ kafka_2.11-1.1.1/bin/windows/zookeeper-server-stop.bat kafka_2.11-1.1.1/bin/windows/zookeeper-shell.bat kafka_2.11-1.1.1/bin/windows/kafka-console-producer.bat kafka_2.11-1.1.1/bin/windows/kafka-console-consumer.bat kafka_2.11-1.1.1/bin/windows/connect-standalone.bat [root@zookeeper2 ~]# tar -zxvf kafka_2.11-1.1.1.tgz kafka_2.11-1.1.1/ kafka_2.11-1.1.1/LICENSE kafka_2.11-1.1.1/NOTICE kafka_2.11-1.1.1/bin/ kafka_2.11-1.1.1/bin/kafka-preferred-replica-election.sh kafka_2.11-1.1.1/bin/connect-standalone.sh kafka_2.11-1.1.1/bin/kafka-server-start.sh kafka_2.11-1.1.1/bin/windows/ kafka_2.11-1.1.1/bin/windows/zookeeper-server-stop.bat kafka_2.11-1.1.1/bin/windows/zookeeper-shell.bat kafka_2.11-1.1.1/bin/windows/kafka-console-producer.bat kafka_2.11-1.1.1/bin/windows/kafka-console-consumer.bat kafka_2.11-1.1.1/bin/windows/connect-standalone.bat [root@zookeeper3 ~]# tar -zxvf kafka_2.11-1.1.1.tgz kafka_2.11-1.1.1/ kafka_2.11-1.1.1/LICENSE kafka_2.11-1.1.1/NOTICE kafka_2.11-1.1.1/bin/ kafka_2.11-1.1.1/bin/kafka-preferred-replica-election.sh kafka_2.11-1.1.1/bin/connect-standalone.sh kafka_2.11-1.1.1/bin/kafka-server-start.sh kafka_2.11-1.1.1/bin/windows/ kafka_2.11-1.1.1/bin/windows/zookeeper-server-stop.bat kafka_2.11-1.1.1/bin/windows/zookeeper-shell.bat kafka_2.11-1.1.1/bin/windows/kafka-console-producer.bat kafka_2.11-1.1.1/bin/windows/kafka-console-consumer.bat kafka_2.11-1.1.1/bin/windows/connect-standalone.bat 第二步 修改三个节点的配置文件 [root@zookeeper1 ~]# cd kafka_2.11-1.1.1/config/ [root@zookeeper1 config]# vi server.properties [root@zookeeper2 ~]# cd kafka_2.11-1.1.1/config/ [root@zookeeper2 config]# vi server.properties [root@zookeeper3 ~]# cd kafka_2.11-1.1.1/config/ [root@zookeeper3 config]# vi server.properties 第三步 启动服务 [root@zookeeper1 bin]# ./kafka-server-start.sh -daemon[root@zookeeper1 bin]# ./kafka-server-start.sh -daemon ../config/server.properties [root@zookeeper1 bin]# jps 6917 Kafka 5992 QuorumPeerMain 6943 Jps [root@zookeeper2 bin]# ./kafka-server-start.sh -daemon[root@zookeeper1 bin]# ./kafka-server-start.sh -daemon ../config/server.properties [root@zookeeper2 bin]# jps [root@zookeeper3 bin]# ./kafka-server-start.sh -daemon[root@zookeeper1 bin]# ./kafka-server-start.sh -daemon ../config/server.properties [root@zookeeper3 bin]# jps 测试服务 [root@ zookeeper1bin]#./kafka-topics.sh --create --zookeeper 192.168.200.40:2181 --replication-factor 1 --partitions 1 --topic test Created topic "test". 出现created topic “test”显示成功
返回至
1+X中级A卷:kafka集群
。
导航菜单
个人工具
登录
命名空间
页面
讨论
变种
视图
阅读
查看源代码
查看历史
更多
搜索
导航
首页
最近更改
随机页面
帮助
工具
链入页面
相关更改
特殊页面
页面信息