zoukankan      html  css  js  c++  java
  • 设置KAFKA

    让我们继续下载并设置Kafka,启动zookeeper,集群,生产者和消费者。

     
    tar -xzf kafka_2.9.1-0.8.2.2.tgz 
    cd kafka_2.9.1-0.8.2.2
    • 由于Kafka使用Zookeeper,所以首先需要启动它,请按照以下步骤操作:
    sh bin/zookeeper-server-start.sh config/zookeeper.properties
    • 现在启动Kafka服务器:
    sh bin/kafka-server-start.sh config/server.properties
    • 一旦服务器启动,我们现在需要创建一个主题,说“测试”

    sh bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

    • 要检查主题是否已成功创建,请使用list命令:
    sh bin/kafka-topics.sh --list --zookeeper localhost:2181
    • 现在让我们开始生产者和消费者,如下所述:
    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
    bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test
    • 现在通过在Producer控制台上键入它来发送一些消息,一旦按下输入,相同的消息应该是消费者控制台上的消费者。

    生成器生成的消息在Consumer上消耗后,表明您正确设置了Kafka。

  • 相关阅读:
    CentOS6.4 安装nmon
    CentOS6.4 访问域局网中Windows的共享
    将类似 12.56MB 36.89KB 转成 以K为单位的数字【备忘】
    ICE中间件相关
    HDFS介绍
    漫画描述HDFS工作原理
    离线安装Cloudera Manager 5和CDH5
    storm集群相关资料
    kafka相关资料
    jstatd
  • 原文地址:https://www.cnblogs.com/a00ium/p/10947026.html
Copyright © 2011-2022 走看看