蔴牛 2017-07-19 03:17 采纳率: 0%
浏览 16784

kafka的消息只能被consumer group中的一个消费者消费，那这个group的意义何在？

比如说，我现在有A,B,C三个机器，都作为console-consumer，若三个消费者放在一个群里，按我的理解，这个群里的每个人都应该接受到订阅的所有信息的啊，如果只有一个能消费，那何必要放在一个群里呢？

  • 写回答

5条回答 默认 最新

  • 逗比123号 2017-07-19 06:12
    关注

    一个group内的消费者只能消费一次消息，不管有多少消费者。你要消费多次的话，就用多个group呗

    评论

报告相同问题？

  • 停止如此使用 @KafkaListener：一个被忽视的 Spring Boot 反模式
    2025-05-20 14:28
    长河的博客 本文深入探讨了这些潜在问题，并提出了构建健壮Kafka消费者的最佳实践，包括手动管理偏移量、智能重试策略、合理并发规划、保障消息顺序、健壮的反序列化处理、优雅应对再均衡以及全面的可观测性。通过这些措施，...
  • Kafka详解(包括kafka集群搭建)
    2022-09-29 23:13
    毫无感情的dj的博客 对kafka细致的解析，从理论到集群搭建实战
  • 菜鸟的Kafka完整入门学习笔记，修订一
    2020-09-01 09:20
    5akura的博客 文章目录一、Kafka概述1.1、定义1.2、消息队列（MQ）1.2.1、传统应用场景——异步处理1.2.2、使用消息队列的优点1.2.3、消息队列的两种模式1.3、Kafka架构二、快速入门2.1、安装配置与部署2.2、Kafka命令行操作三、...
  • 大数据Flink Sink
    2021-09-08 21:54
    赵广陆的博客 Connectors3.1 JDBC3.2 Kafka3.2.1 pom依赖3.2.2 参数设置3.2.3 参数说明3.2.4 Kafka命令3.2.5 代码实现-Kafka Consumer3.2.6 代码实现-Kafka Producer3.3 Redis 1 预定义Sink 1.1 基于控制台和文件的Sink ⚫ API ...
  • kafka概要架构
    2018-03-15 16:38
    fengtangzheng的博客 Kafka是分布式发布-订阅消息系统， Kafka是一个分布式的，可划分的，冗余备份的持久性的日志服务。它主要用于处理活跃的流式数据。Kafka的基本架构如下图：Kafka的架构比较简单，producer、broker和consumer均可以...
  • SpringBoot-Kafka使用（四）
    2019-03-16 23:36
    Think-More的博客 可以使用转发功能实现业务解耦，系统A从Topic-A中获取到消息，进行处理后转发到Topic-B中，系统B监听Topic-B获取消息再次进行处理，这个消息可以是订单相关数据，系统A处理用户提交的订单审核，系统B处理订单的物流...
  • kafka文档（6）－－－－0.10.1－Introduction－基本介绍
    2016-12-15 20:58
    录事参军的博客 Kafka™ is a distributed streaming platform. What exactly does that mean? kafka是分布式流式平台，到底是什么意思呢？ We think of a streaming platform as having three key capabilities: It lets ...
  • 【Spark Streaming】Spark Day11：Spark Streaming 学习笔记
    2021-11-28 15:33
    秒懂AI+的博客 Spark Day11：Spark Streaming 01-[了解]-昨日课程内容回顾 主要讲解：Spark ... - 大数据架构：Lambda架构 离线分析，实时计算 分为三层： - 批处理层，BatchLayer - 速度层，SpeedLayer - 服务
  • elasticSearch的安装与使用
    2018-12-27 20:45
    qq_37001101的博客  #①创建一个索引库 (客户端向远程es服务器发送请求的方式包括：get,post,put,delete等等)  curl -XPUT ‘http://JANSON01:9200/bigdata’  返回值{"acknowledged":true,"shards_acknowledged":true,"index":...
  • java面试题总结
    2020-05-06 15:56
    lizhen1114的博客 答:进程是所有线程的集合，每一个线程是进程中的一条执行路径，线程只是一条执行路径。 为什么要用多线程？ 答:提高程序效率 多线程创建方式？ 答:继承Thread或Runnable 接口。 是继承Thread类好还是实现...
  • 没有解决我的问题, 去提问