首页 > 编程语言 >java——spring boot集成kafka——单播与多播消息的实现

java——spring boot集成kafka——单播与多播消息的实现

时间:2023-03-25 19:36:07浏览次数:41  
标签:多播 消费 java 消费者 -- spring kafka 单播 消息

单播消息的实现:

 

 

 

单播消息:⼀个消费组⾥ 只会有⼀个消费者能消费到某⼀个topic中的消息。于是可以创建多个消费者,这些消费者在同⼀个消费组中。

 

 

创建一个消费者,此消费者属于消费组testGroup,获取borker为:10.31.167.10:9092中    主题为test的消息;

 

./kafka-console-consumer.sh --bootstrap-server 10.31.167.10:9092 --consumer-property group.id=testGroup --topic test

 

 

 属于同一消费组中的消费者,同一时刻,只能有一个消费者能获取消息,其他的不能获取。

 

 

 

=======================================================================================

 

 

 

 

创建一个broker:

 

 

 

 

 

 

 

 打开第一个消费者:

 

 

 

 

 

 

 

 打开第二个消费者,2个消费者都属于同一个消费组:

 

 

 

 

 

 

 

 

 

 

 

 

 第二个消费者上线后,第一个消费者就接收不到消息了。(只能接收新的发送消息,之前的接收不到了——同一个消费组)

 

 

 

 

 

 

 

 

 

 

 

 

 =============================================================================

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

标签:多播,消费,java,消费者,--,spring,kafka,单播,消息
From: https://www.cnblogs.com/xiaobaibailongma/p/17255409.html

相关文章

  • Java多线程
    一、多线程简介 Java多线程是指在一个程序中同时执行多个线程(线程就是一条执行路径)。Java中的多线程可以提高程序的运行效率和并发性,通常用于执行一些耗时的操作或需要同......
  • Spring之异步任务@Async详解分析
    目录1异步@Async详解1.1引言1.2异步说明和原理1.3@Async使用1.3.1启动类中增加@EnableAsync1.3.2方法上加@Async注解1.4@Async异步线程池1.4.1默认线程池1.4.3在......
  • Java获取系统时间的4种方法
    Java获取系统时间的4种方法1publicDateTime(){2//1.设置时间格式3/*4*yyyy-MM-dd:年-月-日2023-03-255......
  • Java IO详解
    一、IO简介1.概念 JavaIO(Input/Output)是Java编程语言对输入和输出(I/O)进行封装的一组类和接口,JavaIO提供了输入流和输出流的抽象,可以使开发者以相同的方式读写......
  • Spring Cloud Alibaba系列(四)微服务网关Gateway及在网关上用sentinel进行限流熔断
    SpringCloudGateway是基于Netty,使用Reactor连接方式的,采用非阻塞方式,相比zuul支持更高的并发,且zuul已经停止维护,我们应该使用Gateway来构建微服务应用。一.使用nacos实......
  • 使用 Docker 打包 Java 应用程序为镜像
    创建Dockerfile在Docker中,Dockerfile是一个文本文件,包含一系列的指令,用于定义如何构建Docker镜像。可以通过编写Dockerfile来自定义Docker镜像。对于Java应用......
  • java——spring boot集成kafka——单节点示例
    首先安装一个zk。然后再安装kafka:   执⾏以下命令创建名为“test”的topic,这个topic只有⼀个partition,并且备份因⼦也设置为1: 然后在kafka节点下,执行如下命令:......
  • SpringBoot集成SpringBootAdmin实现监控
    效果展示客户端maven引用<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifa......
  • Java进阶基础知识点(包及final关键字、常量)
    一:包的概述包就是文件夹,用来管理各种不同功能的Java类,方便后期代码维护。包的命名规则:公司域名的反写+包的作用,需要全部英文小写,见名知意。例如;com.51cto.domain.student.......
  • Spring
    1.简介Spring是一个免费的开源框架(容器)Spring是一个轻量级、非入侵式的框架控制反转(IOC),面向切面(AOP)编程支持事务处理,对框架整合也支持2.组成-七大模块3.IOC理论推......