汇合2.0.0Kafka0.9更换端口时出现问题

kd3sttzy  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(320)

看到合流2.0.0Kafka0.9的一些奇怪的行为,不知道有没有人有什么想法。我在9092上用纯文本监听器建立了一个经纪人。效果很好。我正试图改变它,以听取不同的端口。我试了9095。当它启动时,我在日志中看到:

[2016-01-14 18:11:43,511] INFO Awaiting socket connections on 0.0.0.0:9095. (kafka.network.Acceptor)

但后来,我看到了这个

[2016-01-14 18:11:43,906] INFO Registered broker 0 at path /brokers/ids/0 with addresses: PLAINTEXT -> EndPoint(ec2-54-164-3-183.compute-1.amazonaws.com,9092,PLAINTEXT) (kafka.utils.ZkUtils)

这是关于,为什么它仍然注册在9092???
在这一点上,如果我试着在9095上生产,我会得到很多这样的东西,直到我杀死它:

[2016-01-14 18:14:42,614] WARN Error while fetching metadata with correlation id 0 : {plaintext=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2016-01-14 18:14:42,745] WARN Error while fetching metadata with correlation id 1 : {plaintext=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2016-01-14 18:14:42,850] WARN Error while fetching metadata with correlation id 2 : {plaintext=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
...

如果我试着在9092上生产,1分钟后它就失败了:

[2016-01-14 18:30:11,845] ERROR Error when sending message to topic plaintext with key: null, value: 10 bytes with error: Failed to update metadata after 60000 ms. (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)

我想这可能与我的主机名设置不当有关。。。但我不知道怎么做。。。仅供参考这是一个ec2示例。主机名是ip-10-0-0-22/etc/主机

127.0.0.1 localhost

公共dns是ec2-54-164-3-183.compute-1.amazonaws.com。在我的server.properties中

advertised.host.name=ec2-54-164-3-183.compute-1.amazonaws.com

(上一次我发现我必须设置为能够从amazon外部连接到代理)。
所以。。。KafkaMaven有什么建议吗?

guicsvcw

guicsvcw1#

原来我需要使用adverted.listeners。我敢打赌alexander zolotko使用adverted.port的建议也会奏效,尽管我没有尝试。

wlsrxk51

wlsrxk512#

advertised.port 可以显式设置为的属性 9095 .

相关问题