2016-03-26 20 views
0

3 düğümlü bir küme (google bulut) oluşturdum. Zookeeper tüm düğümlerde koşuyor ve köle düğümlerinden birinde Kafka'yı başlattım. Kümedeki herhangi bir makineden iletişim kurabilir (yayınlayabilir/tüketebilirim) ancak uzaktaki bir makineden bağlanmaya çalıştığımda bir NoBrokersAvailable istisnası alıyorum.Kafka - Fail Bağlanıyor Uzak Broker - HayırBrokersKullanılabilir

Test için güvenlik duvarında bağlantı noktaları açtım ve Kafka yapılandırmasında advertised_host ve bağlantı noktasıyla uğraşmaya çalıştım ancak bağlanamıyorum.

Beklenen yapılandırma nedir? - Uygun varsayılanlara sahip olmama, konfigürasyonun hem dahili hem de uzak durumda çalışmasını beklerdim, ama olmaz. Zookeeper/kafka'nın yapılandırmasının hangi kısmının bunu düzeltmeme izin vereceğinden emin değilim. Ne yapılmalı?

+0

Orada sadece yol çok şey elinden vardır - makineler örneğin iptables'leri çalıştırıyor olabilir. Ya da belki Zookeeper ve Kafka, yönlendirilemeyen IP adreslerini dinliyor (ör. "10.x.x.x1" veya "192.168.x.x") veya bunun ne olabileceğini kim bilebilir? –

+0

Teşekkürler David. Kayıt edilmiş. Ağa bakacağım ve eğer (hiç) alt kısmına gidersem kayıt için buraya not edeceğim. – ismisesisko

+0

güncelleme ancak neşe yok: Ben basitleştirilmiş konular. zookeeper ve kafka ile bir düğüm kullandım. Bazı faydalar sağlayan konfluent kafka distro kullanılır. Yerel olarak ve uzaktan kontrol ettim, zookeeper'ın doğru şekilde yapılandırıldığını doğrulayan ve söz konusu dinlenme sunucusuna harici olarak bağlanabileceğim REST sunucusuyla. Kafka'yı başlattığımda, çıkış satırına dikkat ediyorum:> Kayıtlı broker 0 yol/broker/ids/0 adreslerinde: PLAINTEXT -> EndPoint (küme-3-m, 9092, PLAINTEXT). 'Küme-3-m' yazdığı yerde, öncelikle PUBLIC IP kullanıyordum. Açıkça, komisyoncu başlatıldı ve bağlı - python istemcisi aksini söylüyor! – ismisesisko

cevap

0

advertised.listeners=PLAINTEXT://<broker_ip>:9092 dosyasını server.properties dosyasında ayarlayın. Yeniden kafka-sunucu ve yapımcı yanı sıra (her ikisi de eğer çalışıyorsa hangisi ya) tüketici

başka bir iş parçacığı aynı sorunun cevabım kontrol edin

NoBrokersAvailable: NoBrokersAvailable-Kafka Error