zoukankan      html  css  js  c++  java
  • CentOS 6.7安装Kafka 0.10.1

    master

    [root@master ~]# wget http://apache.fayea.com/kafka/0.10.1.0/kafka_2.10-0.10.1.0.tgz
    [root@master ~]# tar -zxvf kafka_2.10-0.10.1.0.tgz
    [root@master ~]# mv kafka_2.10-0.10.1.0 /usr/local/
    

    [root@master ~]# vi /usr/local/kafka_2.10-0.10.1.0/config/server.properties
    1. 修改

      zookeeper.connect=localhost:2181

      zookeeper.connect=master:2181,slave:2181
    2. 添加

      host.name=master

    保存退出


    [root@master ~]# rsync -av /usr/local/kafka_2.10-0.10.1.0 slave:/usr/local/

    slave

    [root@slave ~]# vi /usr/local/kafka_2.10-0.10.1.0/config/server.properties

    修改

    broker.id=0
    host.name=master
    

    broker.id=1
    host.name=slave
    

    保存退出

    启动Kafka

    master

    [root@master ~]# cd /usr/local/kafka_2.10-0.10.1.0/
    [root@master kafka_2.10-0.10.1.0]# bin/kafka-server-start.sh -daemon config/server.properties
    

    slave

    [root@slave ~]# cd /usr/local/kafka_2.10-0.10.1.0/
    [root@slave kafka_2.10-0.10.1.0]# bin/kafka-server-start.sh -daemon config/server.properties
    

    • 最后,检验是否安装成功。使用 Kafka 自带的客户端检测。进入 Kafka 安装主目录,先启动生产者进入交互客户端模式

    master

    创建一个名为 test 的主题

    [root@master kafka_2.10-0.10.1.0]# bin/kafka-topics.sh --create --zookeeper master:2181 --replication-factor 1 --partitions 1 --topic test

    在一个终端上启动一个生产者

    [root@master kafka_2.10-0.10.1.0]# bin/kafka-console-producer.sh --broker-list master:9092 --topic test

    slave

    在另一个终端中启动消费者,进入交互客户端

    [root@slave kafka_2.10-0.10.1.0]# bin/kafka-console-consumer.sh --zookeeper master:2181 --topic test --from-beginning

    在master(生产者)上,键盘输入Hello World!;之后在slave(消费者)上,屏幕有同样的信息输出。证明 Kafka 集群已经搭建成功。

  • 相关阅读:
    python中的zip()函数和map()函数
    Unity3d插件推荐
    使用Unity3d的Physics.Raycast()的用法做子弹射击
    Unity3D集成SVN进行版本控制
    WVGA-维基百科
    Unity3D之如何创建正确的像素比在屏幕上
    Unity3D如何获取对象和子对象
    Thread: BooleanRT : Realtime 3D boolean operations for (Runtime,Editor)
    Unity3D GUI中的图片跟随鼠标旋转脚本
    三维软件转Unity的系统单位设置研究
  • 原文地址:https://www.cnblogs.com/Genesis2018/p/9079783.html
Copyright © 2011-2022 走看看