zoukankan      html  css  js  c++  java
  • Ubuntu18.04+kafka

    1.下载压缩包https://www.apache.org/dyn/closer.cgi?path=/kafka/2.8.0/kafka_2.13-2.8.0.tgz

    2.由于kafka是Java编辑的需要安装Java环境

    更新软件包

    sudo apt-get update

    安装openjdk-8-jdk

    sudo apt-get install openjdk-8-jdk

    查看java版本,看看是否安装成功

    java -version

    3.解压之前下载的压缩包,放到自己建好的路径下

    4. 开始进行服务开启

    cd kafka_2.13-2.8.0

    bin/zookeeper-server-start.sh config/zookeeper.properties   启动服务

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

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

    bin/kafka-topics.sh --list --zookeeper localhost:2181    通过list命令查看创建的topic

    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test    发送消息

    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning  接收消息(重新开启一个终端cd当文件夹kafka_2.13-2.8.0下 然后输入这个就好了)

    云在青天水在瓶
  • 相关阅读:
    struts2.1.6存在中文乱码的bug
    记Spring下autowire为name时的一个现象
    AOP注解不起作用的debug结果
    占位
    占位
    Hibernate学习小结
    Struts2学习笔记
    金尚网上商城项目第一章小结
    JavaWeb 学习的第一阶段总结
    大话设计模式 笔记——策略模式
  • 原文地址:https://www.cnblogs.com/flms/p/14963338.html
Copyright © 2011-2022 走看看