1. Toy模板网首页
  2. > Toy博客

Kafka Group coordinator xxx:9092 (id: xxx rack: null) is unavailable or invalid

9月前 作者：DanielMaster 分类：Toy博客 阅读(32) 违法举报

这篇具有很好参考价值的文章主要介绍了Kafka Group coordinator xxx:9092 (id: xxx rack: null) is unavailable or invalid。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

问题描述：

Kafka本身启动和相互通信没有问题，但是在使用Java API 模拟消费者连接到Kafka的时候出现报错
discovered group coordinator,Kafka,kafka

2022-03-03 09:31:22[Consumer clientId=consumer-1, groupId=test-consumer-group] Discovered group xxx:9092 (id: xxx rack: null)
2022-03-03 09:31:34[Consumer clientId=consumer-1, groupId=test-consumer-group] Group coordinator xxxt:9092 (id: xxx rack: null) is unavailable or invalid, will attempt rediscovery

原因分析：

我们可以注意一下控制台给出的域名地址，这个域名可能是因为解析问题或者限于远程服务器的安全策略做了转换

验证这个问题的办法，在windows开启telnet命令，在cmd中

telnet xxx 9092

发现是无法连接的

解决方案：

使用管理员权限手动在C:\Windows\System32\drivers\etc\hosts文件中添加映射，手动让自己的电脑认识这个IP

格式：

kafka服务器的ip和kafka服务器对应的域名

example:

# localhost name resolution is handled within DNS itself.
#	127.0.0.1       localhost
#	::1             localhost
192.168.98.101 hadoop01

在此连接到kafka，成功连接
discovered group coordinator,Kafka,kafka文章来源地址https://www.toymoban.com/news/detail-573075.html

到了这里，关于Kafka Group coordinator xxx:9092 (id: xxx rack: null) is unavailable or invalid的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处： 如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：
领支付宝红包 赞助服务器费用

相关文章

  • kafka发送数据报错： Error connecting to node xxxxx:9092 (id: 1 rack: null)java.net.UnknownHostExceptio

    报错内容： warn报错：  [kafka-producer-network-thread | producer-1] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error connecting to node xxxxx:9092 (id: 1 rack: null) java.net.UnknownHostException: xxxxx     at java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)     at java.base/java.net.

    2024年02月08日
    浏览(42)

  • 命令消费kafka报错(id: -1 rack: null) disconnected

    CDP 717环境使用 kafka-console-consumer 命令消费kafka报错如下 是因为kafka开启了kerberos 具体检查可见 1、In Cloudera Manager, navigate to Kafka Configuration . 2、Set SSL Client Authentication to none . 3、Set Inter Broker Protocol to SASL_PLAINTEXT . 1、创建文件 jaas.conf 注意：这里 principal 不清楚的话可以先执行

    2024年02月05日
    浏览(40)
  • [kafka] 消费没有数据的问题解决Group coordinator lookup failed: The coordinator is not available

    [kafka] 消费没有数据的问题解决Group coordinator lookup failed: The coordinator is not available

    [kafka] 消费没有数据的问题解决Group coordinator lookup failed: The coordinator is not available 目录 前言 一、解决问题 在项目中使用了kafka，生产者可以正常的往里放数据，但是消费者无法获取数据，通过kafka命令获取也无法获取，观察控制台发现，报了如下错误。 排查发现topic中没有

    2024年02月07日
    浏览(37)

  • kafka-报错-The coordinator is not aware of this member

    我在项目里把原来用着的 独立消费者 consumer-group-id 同时当做消费者组来消费分区信息，导致协调器找不到这个 consumer-group-id 注册两个测试 topic 写一个消费者组 启动项目，发送消息 报错日志 查看kafka服务器的消费者状态

    2024年02月13日
    浏览(65)
  • kafka消费者的group id从哪里获取

    kafka消费者的group id从哪里获取

    今天跑了一下kafka的示例demo，突然意识到一个问题。消费者拉取broker的消息时需要指定group id，而生产者将消息发送到broker的时候并不会指定group id，那么消费者的group id从哪里获取呢？ 查阅我的这篇文章 kafka消费者 的3.1小节， 如果不配置该参数，则会抛出异常。为此，笔

    2024年02月11日
    浏览(48)

  • Kafka中的group_id：实现消息分组消费的关键

    Kafka是一种高性能、可扩展的分布式消息系统，被广泛应用于大规模数据流处理的场景。在Kafka中，group_id是一个关键概念，用于实现消息的分组消费。本文将详细介绍group_id的作用和使用方法，并提供相应的源代码示例。 Kafka消息分组消费的概念是指多个消费者协同消费同一

    2024年02月03日
    浏览(37)
  • kafka报错:No group.id found in consumer config, container properties

    kafka报错:No group.id found in consumer config, container properties

    Caused by: java.lang.IllegalStateException: No group.id found in consumer config, container properties, or @KafkaListener annotation; a group.id is required when group management is used. 报错提示没有配置groupid,那么配置groupid即可 配置group-id，重启服务器即可

    2024年02月11日
    浏览(40)
  • 解决There is no PasswordEncoder mapped for the id “null“问题

    解决There is no PasswordEncoder mapped for the id “null“问题

    springsecurity从4.2升级到5.0之后，做简单的登录，出现如下所示的错误： 根据官方文档的资料和网上解决办法，需要做一些修改。 默认情况下与4.2版本不同的是，springsecurity5.0密码加密方式采用了bcrypt的方式，而且密码直接配置在xml文件中，不光是需要使用BCryptPasswordEncoder来加

    2023年04月09日
    浏览(91)
  • 关于Spring中java.lang.NullPointerException: Cannot invoke “xxx“ because “xxx“ is null 的问题

    关于Spring中java.lang.NullPointerException: Cannot invoke “xxx“ because “xxx“ is null 的问题

    当我好不容易编译成功，开始运行时，使用postman测试接口功能时却返回了一个错误： 编译成功开始运行： postman返回： 并在IDEA显示了 java.lang.NullPointerException: Cannot invoke “com.example.mybatisdemo.mapper.StudentMapper.ListStudent()” because “this.studentMapper” is null 错误指向了Service层调用的

    2024年02月05日
    浏览(45)

  • 为什么kafka 需要 subscribe 的 group.id？我们是否需要使用 commitSync 手动提交偏移量？

    消费概念： Kafka 使用消费者组的概念来实现主题的并行消费 - 每条消息都将在每个消费者组中传递一次，无论该组中实际有多少个消费者。所以 group 参数是强制性的，如果没有组，Kafka 将不知道如何对待订阅同一主题的其他消费者。 偏移量 ： 每当我们启动一个消费者时，

    2024年02月12日
    浏览(54)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包，优惠每天领

二维码1

领取红包

二维码2

领红包