一个应用jar包部署三台服务器.
kafka也部署三台
然后应用A,B,C三台都应该去kafka消费者组里创建一个消费者.
但是C却永远不行,怎么重启C都不行.
A和B都可以
我再换台机器D也部署jar,发现D也创建不了消费者
这有哪些原因可能导致? 不太了解kafka
kafka消费者创建不了
- 写回答
- 好问题 0 提建议
- 关注问题
分享- 邀请回答
-
1条回答 默认 最新
三千烦恼丝xzh 2022-08-23 10:17关注同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 无用评论 打赏举报 编辑记录 分享
- 2023-11-17 16:17本文将详细探讨如何在Spring Boot项目中基于Spring Kafka动态创建Kafka消费者。 首先，了解Kafka基本概念：Kafka是一种分布式流处理平台，用于构建实时数据管道和流应用程序。它提供了高吞吐量、低延迟的消息传递，...
- 2020-08-19 07:16Kafka消费者的代码实现一般包括创建KafkaConsumer实例、订阅主题、轮询接收消息等步骤。根据代码片段，以下为消费者的关键知识点： 1. 创建KafkaConsumer实例前需要配置消费者属性，包括Kafka集群的地址（bootstrap...
- 2022-06-03 23:02柳小葱的博客 以及kafka的高效读写的保证，今天我们来介绍kafka中的消费者原理，对往期内容感兴趣的小伙伴可以参考：消费者作为kafka中最重要的部分，如何从主题中消费数据是我们重点关注的地方，话不多说，让我们开始今日份的...
- 2018-07-13 22:23在这个"Kafka大数据 生产者消费者实例"中，我们将探讨如何通过Java编程语言来实现Kafka的生产者和消费者。 首先，我们要理解Kafka中的**生产者（Producer）**，它是负责发布消息到特定主题的组件。在Java中，我们...
- 2025-05-10 16:17大数据洞察的博客 在企业级大数据架构中，Apache Kafka（分布式流处理平台）与 Hadoop（分布式计算框架）是两大核心组件。Kafka 擅长处理实时数据流，提供高吞吐量、低延迟的消息传递；Hadoop 则在批量数据存储与离线处理领域表现卓越...
- 2024-04-14 21:44weixin_46628668的博客 消费者组内的消费者负责消费不同的分区，一个分区只能由组内一个消费者消费。手动提交offset：每次消费完数据之后由消费者自己提交offset信息，分为同步提交（阻塞当前线程，提交offset成功后才消费下一波数据，并且...
- 2023-08-14 19:52艾丽丝的爱情的博客 本文将对Kafka消费者线程的源码进行详细解析，并提供相应的代码示例。在构造方法中，我们传入了Kafka集群的地址、消费者组ID和要消费的主题。总结起来，Kafka消费者线程在大数据处理中起到了关键作用，通过上述源码...
- 2022-01-04 18:10在Kafka消费者配置中，设置`partitionAssignor`属性为自定义的分配器类名。同时，自定义的分配器需要继承`AbstractPartitionAssignor`并重写相关方法： ```java import org.apache.kafka.clients.consumer....
- 2025-04-03 16:00二进制11的博客 Kafka消费者订阅Topic是其消费数据的首要步骤，消费者可以通过多种方式订阅Topic，下面详细介绍订阅机制。
- 2024-07-18 07:45james二次元的博客 Apache Kafka 是一个分布式流处理平台，最初由 LinkedIn 开发，并在 2011 年开源成为 Apache 项目。Kafka 主要用于构建实时数据管道和流应用，具有高吞吐量、低延迟、容错性强等特点。以下是对 Kafka 的详细介绍：
- 没有解决我的问题, 去提问
问题事件
系统已结题
9月1日
已采纳回答
8月24日-
创建了问题
8月23日