看到合流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有什么建议吗?
2条答案
按热度按时间guicsvcw1#
原来我需要使用adverted.listeners。我敢打赌alexander zolotko使用adverted.port的建议也会奏效,尽管我没有尝试。
wlsrxk512#
有
advertised.port
可以显式设置为的属性9095
.