zoukankan      html  css  js  c++  java
  • Linux安装kafka2.3.1基于Scala2.12

    一,先从官网下载:http://kafka.apache.org/downloads

    二,解压压缩包(虽然后缀是tgz,但和gz解压方式一样);然后mv kafka_2.12-2.3.1 /usr/local/

    接着:cd /usr/local/kafka_2.12-2.3.1/,然后由于之前已经安装和启动了zookeeper,所以可以删掉config下的zookeeper.properties文件【不删也行】;

    三,启动 kafka【注意,kafka依赖的zookeeper服务的配置在server.properties里配置,默认是zookeeper.connect=localhost:2181,这里要配置远端的zookeeper集群地址(不过我的zookeeper也是在本地)】

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

    四,创建topic

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

    创建一个名为silentdoer的topic,只有一个副本,一个分区。

    通过list命令查看刚刚创建的topic【输出silentdoer】

    ./bin/kafka-topics.sh --list --zookeeper localhost:2181

    五,启动producer并发送消息启动producer

     ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic silentdoer

    此时窗口变成>输入模式,可以发送消息了【可以直接发,只要消息没有被消费,那么consumer启动后也是能够收到的】

    六,在另一个终端中,启动consumer

    命令如下:

    ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic silentdoer --from-beginning

    启动consumer之后就可以在console中看到producer发送的消息了

    可以开启两个终端,一个发送消息,一个接受消息。

  • 相关阅读:
    react-当前的时:分:秒-每秒更新
    一键回顶部按钮 HTML+CSS+JS+jQuery完成
    JavaScript-浏览器的三种弹窗方式
    网页计算器简单实现加减乘除功能
    Oracle -- 记一次ADG库迁移过程小结 -- 上篇(ADG建库)
    expression解决IE6下固定定位的兼容
    Css攻克Selectors 一
    昨天开通了博客,希望自己争取早点写出东西
    Static关键字的用法
    XSHELL使用教程
  • 原文地址:https://www.cnblogs.com/silentdoer/p/11868808.html
Copyright © 2011-2022 走看看