当前位置: 首页 > news >正文

安装kafka

静态文件安装(单机)

  • 解压到指定目录(解压到 /usr)

    tar -zxf kafka_2.11-2.2.0.tgz -C /usr/
  • 到指定的解压目录下

    cd /usr/kafka_2.11-2.2.0/
  • 配置主机名

    • 查看是否配置了HOSTNAME

      vim /etc/sysconfig/network
    • 没有就新增

      HOSTNAME=主机名
      如下是配置主机名为:CentOS
      ​
      HOSTNAME=CentOS
      那么CentOS就是主机该linux的主机名
      需要重启才能生效!!!!!!!!!!!!!!!!!!!
    • 重启生效

      reboot
    • 查看本机地址

      ifconfig
      ​
      我的ip地址
      172.28.204.91
    • 构建主机名和ip的映射文件

      vim /etc/hosts
      配置信息如下
      172.28.204.91 CentOS
    • 检查是否配置成功

      ping CentOS
  • 修改文件server.properties

    vim config/server.properties
     
    修改点1
    把注释放开
    #listeners=PLAINTEXT://:9092
    改成(CentOS是上面配置的)
    listeners=PLAINTEXT://CentOS:9092
    ​
    修改点2
    zookeeper.connect=localhost:2181
    改成(CentOS是上面配置的)
    zookeeper.connect=CentOS:2181
    ​
    修改点3(保证能对该目录进行读写)
    log.dirs=/usr/kafka-logs
    ​
    修改点4 新增
    advertised.listeners=PLAINTEXT://CentOS:9092
    (默认这个key所在行是注释掉的,正是因为没这个,导致创建topic时总是报错
    No entry found for connection 1006)
  • 启动(后台启动方式,需要先启动zk)

    ./bin/kafka-server-start.sh -daemon config/server.properties
  • 查看是否启动成功

    jps
    如下:说明启动成功了
    6560 Kafka
  • 关闭

    ./kafka-server-stop.sh 
  • 创建topic

    ./bin/kafka-topics.sh --bootstrap-server CentOS:9092 --create --topic topic01 --partitions 1 --replication-factor 1

  • 一些报错及解决
报错1 kafka No entry found for connection 0

解决办法:

在主机的kafka配置文件($KAFKA_HOME/config/server.properties)中:
添加:
advertised.listeners=PLAINTEXT://$IP_A:9092(默认这个key所在行是注释掉的)

其中$IP_A可以是A主机的IP或者hostname(在B主机上能ping通就可以).
————————————————
版权声明:本文为CSDN博主「gerrylon007」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/butterfly5211314/article/details/90199559

http://www.lryc.cn/news/268274.html

相关文章:

  • [MySQL] MySQL 高级(进阶) SQL 语句
  • 创建springboot项目
  • “双十一、二” 业务高峰如何扛住?韵达快递选择 TDengine
  • STM32L432+LIS3DH【加速度传感器】:端侧AI
  • VCG Mesh刚性旋转(变换矩阵)
  • R语言【base】——system.file() 在软件包等中查找文件的完整文件名。
  • HTML制作暴雨特效
  • cesium实现区域贴图及加载多个gif动图
  • blackbox黑盒监控部署(k8s内)tensuns专用
  • “C语言“——scanf()、getchar() 、putchar()、之间的关系
  • Spring Boot3 Web开发技术
  • 学习笔记:数据挖掘与机器学习
  • highcharts的甘特图设置滚动时表头固定,让其他内容跟随滚动
  • ElasticSearch 架构设计
  • HTML---定位
  • JVM高频面试题(2023最新版)
  • webpack学习-7.创建库
  • MQTT - 笔记
  • Django 安装
  • 推荐一个vscode看着比较舒服的主题:Dark High Contrast
  • YCSB 测试表预分区
  • K8s 教程
  • python:改进型鳟海鞘算法(SSALEO)求解23个基本函数
  • Hive-数据模型详解(超详细)
  • docker的常规使用总结
  • CSS 文字弹跳效果
  • 什么是动态IP?静态IP和动态IP有什么区别?
  • Linux 与 Shell
  • 大数据-Hive练习-环比增长率、同比增长率、复合增长率
  • C++ 考前难点总结