新手村@村长 2022-08-29 09:59 采纳率: 70.9%
浏览 45
已结题

kafka消费组创建不了

ABC三台服务器部署kafka
abc三台服务器部署应用
应用启动时会在kafka上创建 消费组 命名方式:ip+应用名
开发环境中a,b,c都创建成功

在测试环境中出现了 a,b创建成功,c创建失败
并且关闭a,b, 只启动c,也创建消费组失败
新启动一台D,也创建消费组失败

重启zk和kafka已经尝试过,无效.
如果重装或者删除zk和kafka数据目录,应该是可以解决.
但是想知道是什么原因导致的, 有人知道吗?

  • 写回答

2条回答 默认 最新

  • 穿条秋裤到处跑 2022-08-29 10:25
    关注

    服务器C的问题，应该和zk没有关系吧，具体看一下报什么错吧

    评论

报告相同问题？

  • kafka消费者创建不了 java kafka linux
    2022-08-23 10:01
    回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
  • 如何在Golang中创建kafka消费者组？
    2017-02-01 18:07
    回答 2 已采纳 The consumer group is specified by the second argument of the cluster consumer "constructor". Here
  • Kafka消费者消费信息经常接收不到 java
    2022-12-21 00:45
    回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
  • Spring Boot+Kafka实战生产级Kafka消费组
    2023-08-06 01:35
    AI天才研究院的博客 Kafka是一个开源分布式消息系统，最初由LinkedIn开发，之后成为Apache项目的一部分。Kafka主要用于大数据实时流处理，具有低延迟、高吞吐量等特点。本文将会从基本概念、术语说明、原理及应用场景三个方面对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 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
  • flink消费kafka数据延迟 flink postgresql scala 有问必答
    2022-01-28 09:47
    回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
  • python 消费 kafka 数据教程
    2020-09-18 06:28
    Python作为一门广泛使用的编程语言，在数据处理和分析方面拥有强大的生态系统。Apache Kafka是一个开源的流处理平台，被广泛用于构建实时数据管道和流应用程序。在Python环境下，消费者Kafka数据是实时数据处理中的...
  • flink消费kafka flink java kafka 有问必答
    2021-07-02 11:07
    回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
  • kafka中的消费拦截器 flink java kafka
    2021-07-05 16:53
    回答 1 已采纳 value的值为[B@1e1e585b这个明显是序列化后的Bytes字节类型嘛你反序列化成string就ok了
  • kafka可以生产无法消费的问题 java kafka
    2022-06-11 10:41
    回答 1 已采纳 给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
  • kafka-consumer:简单的 Scala Kafka 消费者
    2021-06-13 20:04
    而 Scala 是一种功能丰富的编程语言，它与 Java 兼容，并提供了面向对象和函数式编程的特性，使得开发 Kafka 应用程序更加便捷。 首先，确保你已经安装了 Java 开发环境（JDK）并设置了 JAVA_HOME 环境变量。接着，...
  • flinkSQL创建kafka源表，解析ogg-json失败 flink kafka oracle
    2022-08-26 11:43
    回答 1 已采纳 不是大小写问题，你的json里面是大写，代码里面是小写，改一下试试
  • SpringBoot整合kafka及ProtoBuf实现跨平台跨语言的信息交互
    2020-10-28 14:57
    ProtoBuf支持多种编程语言，如Java、C++、Python等，这使得它成为跨平台、跨语言数据交换的理想选择。通过定义.proto文件，我们可以描述数据结构，然后ProtoBuf编译器会为我们生成对应语言的代码，方便在不同语言间...
  • kafka安装包-2.13-3.6.2
    2024-06-16 10:53
    Scala是一种多范式的编程语言，Kafka的API是用Scala编写的，因此这个数字表示的是与哪个版本的Scala API兼容。在这个例子中，是Scala 2.13。 - `3.6.2` 是Kafka本身的版本号。每个版本都会包含新功能、性能优化、bug...
  • 没有解决我的问题, 去提问

问题事件

  • 已结题 （查看结题原因） 8月31日
  • 创建了问题 8月29日

悬赏问题

  • ¥15 短剧的sdk在哪里接入
  • ¥15 求：可不可以提供一些 在国内可以用，低代码不要太难 在电脑上可以下载的 制作app的软件
  • ¥60 找人回答kibana8.14.3二次集成开发，自定义插件ui导航栏如何设置
  • ¥15 fluke高精度万用表8845A型号测交流电压一直跳动，且去掉输入后显示不归零
  • ¥15 不同模型怎么用同一个shader
  • ¥15 安卓启动没有ais proxy与v4l2的log打印
  • ¥15 go怎么读取mdb文件里面的数据
  • ¥60 Matlab联合CRUISE仿真编译dll文件报错
  • ¥15 脱敏项目合作，ner需求合作
  • ¥15 脱敏项目合作，ner需求合作