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

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 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
  • 大数据之kafka消费者
    2022-06-03 23:02
    柳小葱的博客 以及kafka的高效读写的保证，今天我们来介绍kafka中的消费者原理，对往期内容感兴趣的小伙伴可以参考：消费者作为kafka中最重要的部分，如何从主题中消费数据是我们重点关注的地方，话不多说，让我们开始今日份的...
  • kafka消费者迭代器卡死
    2016-10-25 09:13
    回答 4 已采纳 明白了，offset已经指到最后了，然后获取不到数据就一直等待状态，我以为卡死，生产者发送几个数据进去就行了
  • 有关kafka消费者的问题，描述如下
    2016-05-09 11:56
    回答 1 已采纳 你的这个结构首先要换一下。 如果你要去读取group中不同分区中的数据。对于你的consumer端来说，应该是1对1进行读取，也就是说，一个java进程对应一个分区partition。 你自己
  • 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中，我们...
  • flink消费kafka数据延迟 flink postgresql scala 有问必答
    2022-01-28 09:47
    回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
  • Kafka消费者
    2024-04-14 21:44
    weixin_46628668的博客 消费者组内的消费者负责消费不同的分区，一个分区只能由组内一个消费者消费。手动提交offset：每次消费完数据之后由消费者自己提交offset信息，分为同步提交（阻塞当前线程，提交offset成功后才消费下一波数据，并且...
  • Kafka消费者线程在大数据环境中的源码解析
    2023-08-14 19:52
    艾丽丝的爱情的博客 本文将对Kafka消费者线程的源码进行详细解析，并提供相应的代码示例。在构造方法中，我们传入了Kafka集群的地址、消费者组ID和要消费的主题。总结起来，Kafka消费者线程在大数据处理中起到了关键作用，通过上述源码...
  • 没有解决我的问题, 去提问

问题事件

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

悬赏问题

  • ¥15 Stata链式中介效应代码修改
  • ¥15 latex投稿显示click download
  • ¥15 请问读取环境变量文件失败是什么原因？
  • ¥15 在若依框架下实现人脸识别
  • ¥15 网络科学导论，网络控制
  • ¥100 安卓tv程序连接SQLSERVER2008问题
  • ¥15 利用Sentinel-2和Landsat8做一个水库的长时序NDVI的对比，为什么Snetinel-2计算的结果最小值特别小，而Lansat8就很平均
  • ¥15 metadata提取的PDF元数据，如何转换为一个Excel
  • ¥15 关于arduino编程toCharArray()函数的使用
  • ¥100 vc++混合CEF采用CLR方式编译报错