kafka的安装和启动_kafka安装启动-程序员宅基地

技术标签: 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集群。
topic kafka根据消息进行分类,发布到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
在这里插入图片描述

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

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qq_51383106/article/details/123953506

智能推荐

集群 & 负载均衡-程序员宅基地

文章浏览阅读143次。集群(Cluster) 指一组计算机系统构成一个松耦合的多处理器系统,它们之间通过网络实现进程间的通信,实现分布式计算。在客户端看来就像是只有一个服务器。集群可以利用多个计算机进行并行计算从而获得很高的计算速度,也可以用多个计算机做备份,从而使得任何一个机器坏了整个系统还是能正常运行。 集群技术的分类 高可用集群(High Availability,HA):高可用的含义是最大限..._集群拥塞

指针数组的释放_释放指针数组-程序员宅基地

文章浏览阅读2.2k次。指针数组释放时,释放数组中元素指向的内容即可,数组本身是在栈上,因此不需要手动释放示例如下#include<stdio.h>#include<stdlib.h>typedef struct A A;struct A{ int a; char b;};int main(){ A* arr[2]; for (int i = 0; i < 2; i++) { arr[i] = (A*)calloc(1, size_释放指针数组

Error: chaincode install failed with status: 500 - failed to invoke backing ... 的解决方案(fabric2.2版本)-程序员宅基地

文章浏览阅读1.4w次,点赞8次,收藏13次。最近在学习配置fabric2.2的环境,之前步骤都是和fabric1.4一样的,就是最后下载好fabric源码之后,需要切换到2.2版本:cd ~/go/src/github.com/hyperledger/fabric 进入fabric目录git checkout v2.2.0 切换fabric的版本到2.2然后进入test-network文件夹,相继执行:启动 fabric 网络:sudo ./network.sh up在网络上建立通道:sudo ./network.sh createCha_error: chaincode install failed with status: 500 - failed to invoke backing

spring boot/cloud 多服务部署单机启动顺序有依赖的解决办法_springcloud 每个服务要单独启动-程序员宅基地

文章浏览阅读5.2k次。spring boot/cloud 多服务部署单机启动顺序有依赖的解决办法spring cloud 做多服务是很方便的,但为了方便伸缩和计算资源的限制,我们需要在一台主机上部署多个业务实例,也需要这些业务实例开机自启动,我们知道,spring cloud服务或者根据业务需要,各业务服务启动顺序是有依赖关系的。那么我们如何得知一个被依赖的服务已经启动成功了呢,我们就需要代码的简单注入和配_springcloud 每个服务要单独启动

SQL和T-SQL的区别_t-sql和sql的区别-程序员宅基地

文章浏览阅读7.2k次,点赞12次,收藏22次。1、SQL 结构化查询语言(Structured Query Language) 简称SQL是一种特殊目的的编程语言,是一种数据库查询和程序设计语言,用于存取数据以及查询、更新和管理关系数据库系统;同时也是数据库脚本文件的扩展名2、T-SQL T-SQL 即 Transact-SQL,是 SQL 在 Microsoft SQL Server 上的增强..._t-sql和sql的区别

java.lang.unsupportedOperationException:Unable to open DISPLAY_java.lang.unsupportedoperationexception: unable to-程序员宅基地

文章浏览阅读1.5k次。java.lang.reflect.InvocationTargetExceptionCasued by:java.lang.unsupportedOperationException:Unable to open DISPLAY出现这个问题,关键在于了解DISPLAY这个系统变量。DISPLAY变量是用来设置将图形显示到何处.比如CENTOS,你用图形界面登录进去,DISPLA..._java.lang.unsupportedoperationexception: unable to open display

随便推点

数据库存储过程简单介绍_数据库简单的存储过程-程序员宅基地

文章浏览阅读1.1w次,点赞6次,收藏36次。存储过程存储过程就是一条或多条SQL语句的集合 当对数据库进行一系列的操作时 存储过程就可以将这些复杂的操作封装成一个代码块 以便重复使用 大大减少了数据库开发人员的工作量创建存储过程创建存储过程的基本语法CREATE PROCEDURE 存储过程名称([存储过程的参数列表])[存储过程的特性]routine_body存储过程的参数列表语法如下([[IN|OUT|INOUT]参数名..._数据库简单的存储过程

linux网络协议栈分析(八)_linux内核网络协议栈情景分析-程序员宅基地

文章浏览阅读372次。/*####################################### * *author Andy Yixin Deng *Nankai University *email: [email protected] * /*#######################################本贴为原创,如转载请标明出处早期linux中断驱动中分为前半部,和后半部之分(bo_linux内核网络协议栈情景分析

[RK3399][Android7.1] 调试笔记 --- 调换dsi和dsi1两路通道数据_rk3399 dsi1-程序员宅基地

文章浏览阅读3.5k次,点赞4次,收藏6次。Platform: RK3399OS: Android 7.1Kernel: v4.4.83背景:此问题是网友Brian遇到的,需求如下:点一个2560*1600的mipi屏,用的dsi和dsi1,这个屏有8 lane,有两个TCON IC,相当于两个屏了,一组DSI对应一个TCON,现在图像左右反了,所以想左右对调下。相当于用的是dual-channel具体配置可参考rk文档。..._rk3399 dsi1

在ios中fixed定位元素丢失,Date兼容NaN_ios position fixed元素消失-程序员宅基地

文章浏览阅读626次。AphorismPreface差不多有半年没有更新blog了, 现在在新的公司适应了,最近喜得一千金,也慢慢适应了新的生活。今天更新一篇关于最近遇到的 ios fixed定位元素丢失 bugiphonex 上 Date 兼容问一. fixed问题现象手机环境: ios 11.0.3预期的展示效果: 图片显示完成,添加作业按钮正常 fixed定位实际展示效果: 图片显示不全,且fixed 定位元素消失了如下图,添加作业按钮(fixed定位)对应的父元素 高度没有撑开全屏, 这_ios position fixed元素消失

jquery滚动事件添加+消除_jq中添加scroll函数以及移除-程序员宅基地

文章浏览阅读5.3k次。var scrollHandler = function(){ $(window).off("scroll",scrollHandler);//解除bind事件 }; $(window).scroll(scrollHandler);//bind事件_jq中添加scroll函数以及移除

cocos2dx 3.10、3.14新建工程在AndroidStudio3.4.2、3.5.2编译通过总结_cocos2dx 3.10 编译android-程序员宅基地

文章浏览阅读1.3k次。报错:No toolchains found in the NDK toolchains folder for ABI with prefix: mips64el-linux-android解决:修改local.properties,将NDK改为r9d或r10c版本。将File->Project Structure下的Android Gradle Plugin Version改为..._cocos2dx 3.10 编译android

推荐文章

热门文章

相关标签