草庐IT

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

Charte 2024-01-19 原文

一、起初无非就是更改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$)

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

查了网上博客：

由于配置的时候直接使用的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端口，成功：

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

在三台服务器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文件中配置映射。

kafkaTopicCommandadvertisedxffclass后端大数据javalinux

有关部署kafka集群后创建主题超时Timed out waiting for a node assignment. Call:createTopics (kafka.admin.TopicCommand的更多相关文章

  1. ruby - 如何在 Ruby 中顺序创建 PI - 2

    出于纯粹的兴趣，我很好奇如何按顺序创建PI，而不是在过程结果之后生成数字，而是让数字在过程本身生成时显示。如果是这种情况，那么数字可以自行产生，我可以对以前看到的数字实现垃圾收集，从而创建一个无限系列。结果只是在Pi系列之后每秒生成一个数字。这是我通过互联网筛选的结果:这是流行的计算机友好算法，类机器算法:defarccot(x,unity)xpow=unity/xn=1sign=1sum=0loopdoterm=xpow/nbreakifterm==0sum+=sign*(xpow/n)xpow/=x*xn+=2sign=-signendsumenddefcalc_pi(digits

  2. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声？ - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题？更新问题，以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点？我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等)，但我确实想创建一个输出文件。

  3. ruby - 在 Ruby 中实现 `call_user_func_array` - 2

    我怎样才能完成http://php.net/manual/en/function.call-user-func-array.php在ruby中？所以我可以这样做:classAppdeffoo(a,b)putsa+benddefbarargs=[1,2]App.send(:foo,args)#doesn'tworkApp.send(:foo,args[0],args[1])#doeswork,butdoesnotscaleendend 最佳答案 尝试分解数组App.send(:foo,*args)

  4. ruby - 使用 Vim Rails，您可以创建一个新的迁移文件并一次性打开它吗？ - 2

    使用带有Rails插件的vim，您可以创建一个迁移文件，然后一次性打开该文件吗？textmate也可以这样吗？ 最佳答案 你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件，这正是您想要的。我不能代表textmate。 关于ruby-使用VimRails，您可以创建一个新的迁移文件并一次性打开它吗？，我们在StackOverflow上找到一个类似的问题： https://sta

  5. ruby-on-rails - 无法使用 Rails 3.2 创建插件？ - 2

    我对最新版本的Rails有疑问。我创建了一个新应用程序(railsnewMyProject)，但我没有脚本/生成，只有脚本/rails，当我输入ruby./script/railsgeneratepluginmy_plugin"Couldnotfindgeneratorplugin.".你知道如何生成插件模板吗？没有这个命令可以创建插件吗？PS:我正在使用Rails3.2.1和ruby​​1.8.7[universal-darwin11.0] 最佳答案 随着Rails3.2.0的发布，插件生成器已经被移除。查看变更日志here.现在

  6. ruby - 如何使用 RSpec::Core::RakeTask 创建 RSpec Rake 任务？ - 2

    如何使用RSpec::Core::RakeTask初始化RSpecRake任务？require'rspec/core/rake_task'RSpec::Core::RakeTask.newdo|t|#whatdoIputinhere?endInitialize函数记录在http://rubydoc.info/github/rspec/rspec-core/RSpec/Core/RakeTask#initialize-instance_method没有很好的记录；它只是说:-(RakeTask)initialize(*args,&task_block)AnewinstanceofRake

  7. ruby-on-rails - active_admin 目录中的常量警告重新声明 - 2

    我正在使用active_admin，我在Rails3应用程序的应用程序中有一个目录管理，其中包含模型和页面的声明。时不时地我也有一个类，当那个类有一个常量时，就像这样:classFooBAR="bar"end然后，我在每个必须在我的Rails应用程序中重新加载一些代码的请求中收到此警告:/Users/pupeno/helloworld/app/admin/billing.rb:12:warning:alreadyinitializedconstantBAR知道发生了什么以及如何避免这些警告吗？ 最佳答案 在纯Ruby中:classA

  8. ruby - 为什么 SecureRandom.uuid 创建一个唯一的字符串？ - 2

    关闭。这个问题需要detailsorclarity.它目前不接受答案。想改进这个问题吗？通过editingthispost添加细节并澄清问题.关闭8年前。Improvethisquestion为什么SecureRandom.uuid创建一个唯一的字符串？SecureRandom.uuid#=>"35cb4e30-54e1-49f9-b5ce-4134799eb2c0"SecureRandom.uuid方法创建的字符串从不重复？

  9. ruby - 简单获取法拉第超时 - 2

    有没有办法在这个简单的get方法中添加超时选项？我正在使用法拉第3.3。Faraday.get(url)四处寻找，我只能先发起连接后应用超时选项，然后应用超时选项。或者有什么简单的方法？这就是我现在正在做的:conn=Faraday.newresponse=conn.getdo|req|req.urlurlreq.options.timeout=2#2secondsend 最佳答案 试试这个:conn=Faraday.newdo|conn|conn.options.timeout=20endresponse=conn.get(url

  10. ruby-on-rails - 每次我尝试部署时，我都会得到 - (gcloud.preview.app.deploy) 错误响应 : [4] DEADLINE_EXCEEDED - 2

    我是Google云的新手，我正在尝试对其进行首次部署。我的第一个部署是RubyonRails项目。我基本上是在关注thisguideinthegoogleclouddocumentation.唯一的区别是我使用的是我自己的项目，而不是他们提供的“helloworld”项目。这是我的app.yaml文件runtime:customvm:trueentrypoint:bundleexecrackup-p8080-Eproductionconfig.ruresources:cpu:0.5memory_gb:1.3disk_size_gb:10当我转到我的项目目录并运行gcloudprevie

随机推荐