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

kafka的安装和启动

一、kafka介绍
1,kafka简单介绍
kafka是一款分布式、支持分区的、多副本,基于zookeeper协调的分布式消息系统。最大的特性就是可以实时处理大量数据来满足需求。

2,kafka使用场景
1,日志收集:可以用kafka收集各种服务的日志 ,通过已统一接口的形式开放给各种消费者。

2,消息系统:解耦生产和消费者,缓存消息。

3,用户活动追踪:kafka可以记录webapp或app用户的各种活动,如浏览网页,点击等活动,这些活动可以发送到kafka,然后订阅者通过订阅这些消息来做监控。

4,运营指标:可以用于监控各种数据。

3,kafka基本概念
kafka是一个分布式的分区的消息,提供消息系统应该具备的功能。

名称解释
broker消息中间件处理节点,一个broker就是一个kafka节点,多个broker构成一个kafka集群。
topickafka根据消息进行分类,发布到kafka的每个消息都有一个对应的topic
producer消息生产(发布)者
consumer消息消费(订阅)者
consumergroup消息订阅集群,一个消息可以被多个consumergroup消费,但是一个consumergroup只有一个consumer可以消费消息。

 


4,kafka的安装
下载安装包并解压
tar -xzvf


修改配置文件,先进入config文件夹

修改server.proerties文件

默认端口号


修改日志位置


zk地址,服务器ip:2181


在bin目录下启动
./kafka-server-start.sh -daemon …/config/server.properties


查看端口号是否有服务占用,有则启动成功


http://www.kler.cn/a/298594.html

相关文章:

  • 攻防世界 ics-07
  • ChatGPT网络错误如何解决
  • Boost.Asio 同步读写及客户端 - 服务器实现详解
  • 关于Mac使用VSCode连接虚拟机
  • JWT与Token
  • 『SQLite』如何使用索引来查询数据?
  • 面试必问:Java 类加载过程
  • CMake/C++:一个日志库spdlog
  • FreeRTOS-任务创建和删除
  • 分布式算法-Paxos、Raft、ZAB复习
  • 【python2C】算法基础:计时比较
  • UE4_后期处理五—饱和度调整、隔离、扭曲、重影
  • Web3 项目安全手册
  • NXOpenC属性操作
  • Day94 代码随想录打卡|动态规划篇--- 使用最小花费爬楼梯
  • Python Opencv鼠标回调
  • JavaWeb中处理 Web 请求的方式总结
  • 828华为云征文|Flexus云服务器X实例快速部署在线测评平台,适用各种信息学教学
  • UniApp实现漂亮的音乐歌词滚动播放效果
  • k8s 高级调度
  • Goby 漏洞发布|(CVE-2024-45195)Apache OFBiz /viewdatafile 代码执行漏洞【已复现】
  • 使用Flask框架构建RESTful API:从基础到实践
  • 为OneAPI配置MySQL数据库及设置开机启动
  • Windows常用的快捷键
  • 缓存穿透、缓存击穿、缓存雪崩的区别是什么?
  • SprinBoot+Vue停车场管理系统的设计与实现