zoukankan      html  css  js  c++  java
  • kafka服务安装-SuSE Linux Enterprise Server 11 SP3

    kafka是一款分布式消息发布和订阅的系统,具有高性能和高吞吐率。 更多说明请自行了解,直接进入主题.

    kakfa 安装之前需要安装jdk,不做更多说明

    一、下载kafka 

      进入下载页面:http://kafka.apache.org/downloads.html 

    解压

    1 tar -xzf kafka_2.10-0.10.1.0.tgz 
    2 cd kafka_2.10-0.10.1.0

      /bin 启动和停止命令等。 
      /config 配置文件 
      /libs 类库 

    二、启动服务

    运行kafka需要使用Zookeeper,所以你需要先启动Zookeeper,如果你没有Zookeeper,你可以使用kafka自带打包和配置好的Zookeeper。
    bin/zookeeper-server-start.sh config/zookeeper.properties &

    在启动kafka服务

    bin/kafka-server-start.sh config/server.properties &

    三、创建一个主题(topic)

      创建一个名为“test”的Topic,只有一个分区和一个备份:
    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

      创建好之后,可以通过运行以下命令,查看已创建的topic信息:

    bin/kafka-topics.sh --list --zookeeper localhost:2181 test
    四、发送消息 

    Kafka提供了一个命令行的工具,可以从输入文件或者命令行中读取消息并发送给Kafka集群。每一行是一条消息。
    运行producer(生产者),然后在控制台输入几条消息到服务器。

    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
    This is a message
    This is another message

    五、消费消息

    Kafka也提供了一个消费消息的命令行工具,将存储的信息输出出来。

    1 bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
    2 This is a message
    3 This is another message

    这里只是单机测试,参考地址:http://orchome.com/6 

  • 相关阅读:
    js 提升
    omnipay支付--支付宝支付
    laravel 配置sql日志
    laravel monlog配置
    php openssl相关加密解密 验签代码
    laravel validator提示信息中文化
    opendevops_codo项目研究
    Python学习笔记
    shell编程总结
    关于JeeSite开源软件
  • 原文地址:https://www.cnblogs.com/PuShaobin/p/6074744.html
Copyright © 2011-2022 走看看