部署kafka集群后创建主题超时Timed out waiting for a node assignment. Call:createTopics (kafka.admin.TopicCommand

这篇具有很好参考价值的文章主要介绍了部署kafka集群后创建主题超时Timed out waiting for a node assignment. Call:createTopics (kafka.admin.TopicCommand。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、起初无非就是更改server.properties中的配置,以下三项

1.14.247.152的server.properties

broker.id=0
log.dirs=/home/chentongchuan/test/kafka/kafka_2.12-3.0.0/datas
zookeeper.connect=1.14.247.152:2181,159.75.241.252:2181,112.74.188.40:2181/kafka

159.75.241.252的server.properties

broker.id=1
log.dirs=/test/kafka/kafka_2.12-3.0.0/datas
zookeeper.connect=1.14.247.152:2181,159.75.241.252:2181,112.74.188.40:2181/kafka

112.74.188.40的server.properties

broker.id=2
log.dirs=log.dirs=/root/test/kafka/kafka_2.12-3.0.0/datas
zookeeper.connect=1.14.247.152:2181,159.75.241.252:2181,112.74.188.40:2181/kafka

二、分别在三台服务器的bin目录下启动kafka

./kafka-server-start.sh -daemon ../config/server.properties

三、jps命令查看状态启动成功后,连接kafka并创建topics

kafka-topics.sh --bootstrap-server 1.14.247.152:9092 --create --partitions 1 --replication-factor 3 --topic first

报错:

Error while executing topic command : Timed out waiting for a node assignment. Call: createTopics
[2022-03-21 10:43:47,051] ERROR org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: createTopics
 (kafka.admin.TopicCommand$)

大概意思是等待分配结点超时。

查了网上博客:
部署kafka集群后创建主题超时Timed out waiting for a node assignment. Call:createTopics (kafka.admin.TopicCommand

由于配置的时候直接使用的IP,所以也就无需配置映射关系了。所以我尝试了办法1:

advertised.host.name=1.14.247.152
advertised.port=9092

还是同样的超时问题。

又返回server.properties查看:发现在32行左右有这段话

#Hostname and port the broker will advertise to producers and consumers.  # If not set, it uses the value for "listeners" if configured.   
# Otherwise, it will use the value returned from 
# java.net.InetAddress.getCanonicalHostName().

# advertised.listeners=PLAINTEXT://yourhostname:9092

大概意思是:

代理将向生产者和消费者发布主机名和端口。 如果没有设置,则使用“listeners”的值。 否则,它将使用从java.net.InetAddress.getCanonicalHostName()返回的值。 

于是删除advertised.host.name和advertised.port,在三台服务器配置:

advertised.listeners=PLAINTEXT://1.14.247.152:9092

信心满满,启动,连接kafka并创建topics,再次出现相同的超时异常。

由于之前三个服务器,只有两个服务器开了9092端口(阿里/腾讯云安全组规则 + 防火墙关闭,或阿里/腾讯云安全组规则 + 防火墙开放9092端口),此时马上开通所有服务器的9092端口,成功:

部署kafka集群后创建主题超时Timed out waiting for a node assignment. Call:createTopics (kafka.admin.TopicCommand

四、为了验证究竟是配置的问题还是端口未开放的问题

在三台服务器9092端口都开放的情况下:
1、去掉advertised.listeners,加上advertised.host.name和advertised.port:成功
2、去掉advertised.host.name和advertised.port,加上advertised.listeners:成功
3、去掉advertised.host.name和advertised.port、advertised.listeners:成功

结论:不管有没有指定主机和端口,只要端口有开放即可。advertised.xxx其实是代理将向生产者和消费者发布主机名和端口。没有配置的时候,底层会自动通过getCanonicalHostName()来获取。如果配置了主机名,还需要在host文件中配置映射。文章来源地址https://www.toymoban.com/news/detail-418505.html

到了这里,关于部署kafka集群后创建主题超时Timed out waiting for a node assignment. Call:createTopics (kafka.admin.TopicCommand的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

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

领支付宝红包 赞助服务器费用

相关文章

  • Finalshell连接Linux超时之Connection timed out: connect

    BUG原因:每次重启finalshell 还是 CentOS,ip地址存在变化的可能 目录 🍉前言 🌼报错 🌼摸索 💪解决措施 (1)福利 :花了2小时才解决的BUG,希望本篇文章能帮你10分钟解决! (2)tips :ipconfig或ip addr,以及,vim或vi,不同的操作系统有细微区别,比如我现在用CentOs,有些人

    2024年02月04日
    浏览(43)
  • FTP上传超时问题排查 ftpClient.storeFile Connection timed out

    Ftp storeFile 超时日志如下 Caused by: java.net.ConnectException: Connection timed out (Connection timed out) at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) at java.net.Abstract

    2024年02月14日
    浏览(82)
  • 软件测试|解决Github port 443 : Timed out连接超时的问题

    前言 GitHub是全球最大的开源代码托管平台之一,许多开发者和团队使用它来管理和协作开源项目。但在当下,我们在clone或者提交代码时会经常遇到\\\"GitHub Port 443: Timed Out\\\"错误,这意味着我们的电脑无法建立与GitHub服务器的安全连接。这个问题通常由网络问题或防火墙设置引起

    2024年02月07日
    浏览(44)
  • vnc server连不上报错Timed out waiting for a response from the computer

    本地机:Windows11 腾讯云Ubuntu20.04. 尝试过添加防火墙端口,但是找到的 类似这样的解决方法,好像这个云平台的操作系统是centos的,Ubuntu没有yum。 以下是我的解决方法 1、重启机器。 2、重新打开。  参考VNC解决方法:(5条消息) vnc server连不上报错Timed out waiting for a response fr

    2024年02月13日
    浏览(38)
  • 解决 github 无法访问 fatal: unable to access 、超时 Timed out

            github拉取项目提示如下问题         把网络的DNS配置改为 114.114.114.114 即可,操作步骤如下         1. 右键打开 \\\"网络和Internet\\\"设置                  2. 打开 \\\"更改适配器选项\\\"                  3. 右键点击对应网络连接属性                    4. 打

    2024年02月12日
    浏览(67)
  • 解决系统开机启动缓慢,并提示Timed out waiting for device XXX,Dependency failed for XXX.

    一台机器挂载了两块数据盘(/dev/sdb,/dev/sdc) 由于挂载的sdb一直没有使用,数据都放在sdc下,所以操作将它删除,重启后发现机器要一分多钟才可以连接:查看message日志发现有timed out: 近期除删除sdb磁盘外无其他操作,可能是删除磁盘导致的 查看磁盘数据和盘符是否正常: 发

    2024年02月03日
    浏览(56)
  • Gradle在Androidstudio中下载超时提示Download info Connect timed out

            测试环境:Android Studio Giraffe | 2022.3.1 Patch 1         试验7次,成功了3次         下载速度时快时慢         将gradlewrappergradle-wrapper.properties中的地址放到迅雷中下载         如https://services.gradle.org/distributions/gradle-8.0-bin.zip

    2024年02月09日
    浏览(43)
  • Android 解决Connection timed out: connect或者部分第三方库下载超时问题

    之前比较老的项目重新打开,因为Android Studio 版本已经升级,导致原来部分的第三方库需要重新下载,但是因为墙或者其他原因,一直下载超时。后续解决了此问题,在此记录一下。 新版本的Android Studio 在 项目目录下的 settings.gradle 文件中添加如下代码: 旧版本的Android St

    2024年02月20日
    浏览(65)
  • lettuce.core.RedisCommandTimeoutException: Command timed out after 1 minute(s) timeout 60000超时问题

    有一台服务器 java程序不定期会出现Redis command timed out; nested exception is io.lettuce.core.RedisCommandTimeoutException: Command timed out after 1 minute(s) 错误,导致应用出现 timeout 60000 错误,重启应用后,问题修复,但还是会不定期出现该问题。查看应用日志,发现有如下错误: 出现timeout 600

    2024年02月16日
    浏览(51)
  • selenium 全屏截图报错超时Timed out receiving message from renderer: 10.000

    全屏截图代码: 报错信息: 改用以下代码截图,报错消失: 报错可能原因:设置网页全屏后,内容加载过多,会存在超时现象 疑似涉及browser.set_window_size(width, scroll_height)

    2024年02月22日
    浏览(46)

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

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

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

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

二维码1

领取红包

二维码2

领红包