首页 > 编程语言 >java——spring boot集成kafka——kafka介绍以及概念理解

java——spring boot集成kafka——kafka介绍以及概念理解

时间:2023-03-04 17:12:42浏览次数:34  
标签:java spring Broker Kafka 消息 Group kafka Consumer

 

 

 

 

 

 

 

 

 

 

 

 

 

 

首先,让我们来看一下基础的消息(Message)相关术语:

名称解释
Broker 消息中间件处理节点,⼀个Kafka节点就是⼀个broker,⼀个或者多个Broker可以组成⼀个Kafka集群
Topic Kafka根据topic对消息进⾏归类,发布到Kafka集群的每条消息都需要指定⼀个topic
Producer 消息⽣产者,向Broker发送消息的客户端
Consumer 消息消费者,从Broker读取消息的客户端
ConsumerGroup 每个Consumer属于⼀个特定的Consumer Group,⼀条消息可以被多个不同的Consumer Group消费,但是⼀个Consumer Group中只能有⼀个Consumer能够消费该消息
Partition 物理上的概念,⼀个topic可以分为多个partition,每个partition内部消息是有序的

 

标签:java,spring,Broker,Kafka,消息,Group,kafka,Consumer
From: https://www.cnblogs.com/xiaobaibailongma/p/17178594.html

相关文章

  • Java:得到指定年份、月份、周次的最后一天
    使用Java的工具类Calendar通过Calendar可以进行很多的日期操作/***得到指定年份的最后一天*@paramyear*/publicstaticvoidgetLastDayOfYea......
  • java——spring boot集成kafka——消息队列的流派
                   ......
  • 关于 Javascript 的几种继承
    原型链的概念:原型链通俗易懂的理解就是可以把它想象成一个链条,互相连接构成一整串链子而原型链中就是实例对象和原型对象之间的链接每个函数都有一个prototype属性,这个p......
  • 【java】动态修改日志级别
    背景开发过程中,为了方便问题快速定位,都会在代码中增加相关日志生产环境中,为了减少日志输出量,需要提高日志级别,节约资源。如果能动态修改日志级别,当出现问题时,动态降低......
  • 【Java Pro】001-Java基础:面向对象
    【JavaPro】001-Java基础:面向对象文章目录​​【JavaPro】001-Java基础:面向对象​​​​一、面向对象​​​​1、什么是对象​​​​现实生活中的对象与程序中的对象​​......
  • Java 集合 为什么重写 HashCode 和 equals
    #Java集合为什么重写HashCode和equals>Object源码中的HashCode和equals方法:>>```>publicnativeinthashCode();>>publicbooleanequals(Objectobj){>......
  • JavaScript Modal Image
    <!DOCTYPEhtml><html><head><title>JavaScriptModalImage</title></head><styletype="text/css"> .modal{ position:fixed; z-index:1......
  • Java GUI编程(包括awt,event)弹球小游戏功能扩充。
    原网址:https://gitee.com/EdsionKXXX/pinball-game-demo源代码:1packageAWT_GameDemo;234importjavax.swing.*;5importjava.awt.*;6importja......
  • spring学习笔记
    Spring学习笔记官方下载地址:https://repo.spring.io/libs-release-local/org/springframework/spring/GitHub:https://github.com/spring-projects<!--https://mv......
  • java 线程同步
    多种方式可以完成线程同步,传统方法是关键字synchronized完成的,可以是同步方法也可以是同步代码块同步方法@Data@AllArgsConstructor@NoArgsConstructorclassMyThea......