zoukankan      html  css  js  c++  java
  • kafa单机版环境搭建

    1.解压kafka压缩包(移动kafka到/usr/local/下,个人喜好):

      [root@localhost package]# tar -zxvf kafka.tar.gz

    2.修改配置文件config/server.properties

      [root@localhost package]# vim /usr/local/kafka/config/server.properties

      ####broker_id####    替换kafka序号,几台机器分别就是1

      ####host_name####   替换当前机器的hostname

      ####host_name#### 替换当前机器的hostname

      ####Path####    替换kafka安装目录

      zookeeper.connect=####hosts_name####  替换zk集群名称

      参考如下:

      broker.id=1

      host.name=node187

      advertised.host.name=node187

      log.dirs=/home/bigdata/kafka/kafka-logs

      zookeeper.connect=node187:2181,node188:2181,node189:2181

    3.启动kafka(先要确保zookeeper已启动,然后在Kafka目录执行)

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

      如果无报错则说明启动成功。nohup &是实现在后台启动。

    4.查看进程

      jps

      

    5.简单测试

      打开2个终端,分别在Kafka目录执行以下命令

      启动producer

        bin/kafka-console-producer.sh --broker-list 192.168.148.128:9092 --topic test

      启动consumer

        bin/kafka-console-consumer.sh --zookeeper 192.168.148.128:2181 --topic test --from-beginning

  • 相关阅读:
    linux开机启动服务配置
    流媒体服务器配置安装SRS及nginx+rtmp
    WEBRTC配置安装
    linux操作20200825
    转载流媒体服务器相关收藏
    RabbitMQ中间件使用
    如何查找删除指定进程
    硬件接口,串行比并行快的原因
    JavaBean+jsp开发模式 --结合form表单 实例
    session会话
  • 原文地址:https://www.cnblogs.com/ITMan-blogs/p/9061995.html
Copyright © 2011-2022 走看看