新手村@村长 2022-08-23 10:01 采纳率: 70.9%
浏览 30
已结题

kafka消费者创建不了

一个应用jar包部署三台服务器.
kafka也部署三台
然后应用A,B,C三台都应该去kafka消费者组里创建一个消费者.
但是C却永远不行,怎么重启C都不行.
A和B都可以
我再换台机器D也部署jar,发现D也创建不了消费者
这有哪些原因可能导致? 不太了解kafka

  • 写回答

1条回答 默认 最新

  • 三千烦恼丝xzh 2022-08-23 10:17
    关注

    同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论 编辑记录

报告相同问题？

  • kafka消费者创建不了 java kafka linux
    2022-08-23 10:01
    回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
  • Kafka消费者消费信息经常接收不到 java
    2022-12-21 00:45
    回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
  • 如何在Golang中创建kafka消费者组？
    2017-02-01 18:07
    回答 2 已采纳 The consumer group is specified by the second argument of the cluster consumer "constructor". Here
  • springboot 基于spring-kafka动态创建kafka消费者
    2023-11-17 16:17
    本文将详细探讨如何在Spring Boot项目中基于Spring Kafka动态创建Kafka消费者。 首先，了解Kafka基本概念：Kafka是一种分布式流处理平台，用于构建实时数据管道和流应用程序。它提供了高吞吐量、低延迟的消息传递，...
  • 一台机器可以即可以充当kafka消费者又充当kafka生产者吗？ java kafka
    2022-01-10 15:46
    回答 3 已采纳 消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
  • kafka拉取不到数据 java kafka 分布式 有问必答
    2022-02-16 19:32
    回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
  • Springboot集成kafka，应用很卡，消费很慢 java kafka spring boot
    2022-10-25 09:26
    回答 5 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
  • Java实现Kafka生产者消费者代码实例
    2020-08-19 07:16
    Kafka消费者的代码实现一般包括创建KafkaConsumer实例、订阅主题、轮询接收消息等步骤。根据代码片段，以下为消费者的关键知识点： 1. 创建KafkaConsumer实例前需要配置消费者属性，包括Kafka集群的地址（bootstrap...
  • kafka消费者迭代器卡死
    2016-10-25 09:13
    回答 4 已采纳 明白了，offset已经指到最后了，然后获取不到数据就一直等待状态，我以为卡死，生产者发送几个数据进去就行了
  • 有关kafka消费者的问题，描述如下
    2016-05-09 11:56
    回答 1 已采纳 你的这个结构首先要换一下。 如果你要去读取group中不同分区中的数据。对于你的consumer端来说，应该是1对1进行读取，也就是说，一个java进程对应一个分区partition。 你自己
  • kafka中的消费拦截器 flink java kafka
    2021-07-05 16:53
    回答 1 已采纳 value的值为[B@1e1e585b这个明显是序列化后的Bytes字节类型嘛你反序列化成string就ok了
  • 大数据之kafka消费者
    2022-06-03 23:02
    柳小葱的博客 以及kafka的高效读写的保证，今天我们来介绍kafka中的消费者原理，对往期内容感兴趣的小伙伴可以参考：消费者作为kafka中最重要的部分，如何从主题中消费数据是我们重点关注的地方，话不多说，让我们开始今日份的...
  • flink消费kafka flink java kafka 有问必答
    2021-07-02 11:07
    回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
  • kafka大数据 生产者消费者实例
    2018-07-13 22:23
    在这个"Kafka大数据 生产者消费者实例"中，我们将探讨如何通过Java编程语言来实现Kafka的生产者和消费者。 首先，我们要理解Kafka中的**生产者（Producer）**，它是负责发布消息到特定主题的组件。在Java中，我们...
  • Kafka消费者
    2024-04-14 21:44
    weixin_46628668的博客 消费者组内的消费者负责消费不同的分区，一个分区只能由组内一个消费者消费。手动提交offset：每次消费完数据之后由消费者自己提交offset信息，分为同步提交（阻塞当前线程，提交offset成功后才消费下一波数据，并且...
  • 没有解决我的问题, 去提问

问题事件

  • 系统已结题 9月1日
  • 已采纳回答 8月24日
  • 创建了问题 8月23日

悬赏问题

  • ¥15 【求职】怎么找到一个周围人素质都很高不会欺负他人，并且未来月薪能够达到一万以上（技术岗）的工作？希望可以收到写有具体，可靠，已经实践过了的路径的回答？
  • ¥15 Java+vue部署版本反编译
  • ¥100 对反编译和ai熟悉的开发者。
  • ¥15 带序列特征的多输出预测模型
  • ¥15 Python 如何安装 distutils模块
  • ¥15 关于#网络#的问题：网络是从楼上引一根网线下来，接了2台傻瓜交换机，也更换了ip还是不行
  • ¥15 资源泄露软件闪退怎么解决？
  • ¥15 CCF-CSP 2023 第三题 解压缩(50％)
  • ¥30 comfyui openpose报错
  • ¥20 Wpf Datarid单元格闪烁效果的实现