苏默曦 2024-06-17 21:26 采纳率: 50%
浏览 42
已结题

kafka创建topic时报错Failed to create new KafkaAdminClient

kafka和zook已启动

img

创建topic(主题) ,主题名称为test1
[hadoop@node2 kafka_2.12-3.3.1]$ kafka-topics.sh --bootstrap-server node1:9092 --create --partitions 1 --replication-factor 1 --topic test1

img


报错一直未解决

  • 写回答

3条回答 默认 最新

  • 阿里嘎多学长 2024-06-17 21:26
    关注

    以下内容由CHATGPT及阿里嘎多学长共同生成、有用望采纳:


    您好!根据您提供的错误信息和截图,这个问题通常是由于Kafka无法正确解析配置中的bootstrap.servers地址导致的。下面是一些步骤,您可以按照这些步骤来尝试解决这个问题:

    1. 检查Kafka配置: 确保server.properties文件中的bootstrap.servers配置项是正确的。这个配置项应该列出所有Kafka broker的地址和端口,格式通常是host1:port,host2:port

    2. 检查ZooKeeper配置: 如果您的Kafka集群使用ZooKeeper,确保ZooKeeper服务正在运行,并且Kafka配置中的zookeeper.connect指向正确的ZooKeeper地址。

    3. 检查网络和DNS

      • 确保node1这个主机名在您的网络中是可解析的。您可以尝试使用ping node1nslookup node1来检查DNS解析。
      • 如果node1是一个IP地址,确保它在您的网络中是可达的。
    4. 使用IP地址代替主机名: 如果node1是一个主机名,并且您发现DNS解析有问题,您可以尝试在bootstrap.servers配置中使用node1的IP地址代替主机名。

    5. 重新启动Kafka服务: 在修改配置后,确保重新启动Kafka服务以应用更改。

    6. 检查防火墙设置: 确保没有防火墙规则阻止了Kafka服务的端口。

    7. 查看日志文件: 查看Kafka和ZooKeeper的日志文件,可能会有更多关于问题的信息。

    下面是修改bootstrap.servers配置的一个示例:

    # server.properties
    bootstrap.servers=node1:9092,node2:9092
    

    请将node1替换为实际的主机名或IP地址,9092是Kafka的默认端口,如果您的设置不同,请相应地修改。

    如果您需要进一步的帮助,请提供更多的信息,例如您的Kafka和ZooKeeper配置文件内容,以及网络环境的详细信息。希望这些信息能帮助您解决问题!

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论 编辑记录
查看更多回答(2条)

报告相同问题?

问题事件

  • 已结题 (查看结题原因) 6月17日
  • 已采纳回答 6月17日
  • 创建了问题 6月17日

悬赏问题

  • ¥15 35114 SVAC视频验签的问题
  • ¥15 impedancepy
  • ¥15 在虚拟机环境下完成以下,要求截图!
  • ¥15 求往届大挑得奖作品(ppt…)
  • ¥15 如何在vue.config.js中读取到public文件夹下window.APP_CONFIG.API_BASE_URL的值
  • ¥50 浦育平台scratch图形化编程
  • ¥20 求这个的原理图 只要原理图
  • ¥15 vue2项目中,如何配置环境,可以在打完包之后修改请求的服务器地址
  • ¥20 微信的店铺小程序如何修改背景图
  • ¥15 UE5.1局部变量对蓝图不可见