Kafka, java.nio.channels.ClosedChannelException'ı atar

Kafka konsol aracıyla ec2'de barındırılan kafka sunucusundan ileti almaya çalıştığımda (V 0.9.0.1, bunun eski tüketici API'lerini kullandığını düşünüyorum) Aşağıdaki istisnaları alıyorum . Bunu nasıl aşabilirim? .Kafka, java.nio.channels.ClosedChannelException'ı atar

#/kafka-console-consumer.sh --zookeeper zookeeper1.xx.com:2181 --topic MY_TOPIC Bu aslında UYARI olduğunu

[2016-04-06 14:34:58,219] WARN Fetching topic metadata with correlation id 0 for topics [Set(MY_TOPIC)] from broker [BrokerEndPoint(1014,kafka3.xx.com,9092)] failed (kafka.client.ClientUtils$) 
java.nio.channels.ClosedChannelException 
    at kafka.network.BlockingChannel.send(BlockingChannel.scala:110) 
    at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:75) 
    at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:74) 
    at kafka.producer.SyncProducer.send(SyncProducer.scala:119) 
    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) 
    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94) 
    at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66) 
    at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) 
[2016-04-06 14:34:58,222] WARN Fetching topic metadata with correlation id 0 for topics [Set(MY_TOPIC)] from broker [BrokerEndPoint(1013,kafka22.xx.com,9092)] failed (kafka.client.ClientUtils$) 
java.nio.channels.ClosedChannelException 
    at kafka.network.BlockingChannel.send(BlockingChannel.scala:110) 
    at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:75) 
    at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:74) 
    at kafka.producer.SyncProducer.send(SyncProducer.scala:119) 
    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) 
    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94) 
    at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66) 
    at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) 
[2016-

kaynak

2016-04-06 Ratha

orijinal kapalı kanal istisna sebebi ben aynı tip sorunu lütfen bir göz verir benim yerel barındıran tüm konular için sanmıyorum

kaynak

2016-04-06 06:47:21 Ratha

İpucu için çok teşekkürler. Bir süre hem cildimde hem de penceremde aynı problemi yaşadım. Her iki makinede de ´hosts´ dosyasını tamir ettiğimde hata ortadan kayboldu! – johnshumon

--from-başlayan - hayır büyük anlaştık mı. Konunun bozulmuş olabilir mi? Konuyu yeniden oluşturmaya çalışın.

kaynak

2016-04-06 06:02:28 ponkin

dosyasını düzenleyerek çözmüş bazı DNS sorunu vardı, olup http://stackoverflow.com/questions/36442668/failed-to-add-leader-for-partitions-in-kafka – Ratha

Yeni tüketici ile ilgili birçok soruna yanıt veriyorum, yoklama mesajları olmadan sonsuz döngüdür. Yani, eski tüketici API'leri ile boğulmak (kafka dağıtımı ile tüketici konsolu araçları) ve şimdi bu tür kapalı kanal sorunları almak için belirtildi – Ratha

http://stackoverflow.com/questions/36393867/if-my- üretici-üreten-sonra-neden-the-tüketici-couldnt-tüketmek-it-stuck-pol http://stackoverflow.com/questions/36439818/warn-error-while-fetching-metadata-with-correlation-id-1 -my-topic-invalid-to – Ratha

Kafka, java.nio.channels.ClosedChannelException'ı atar

cevap

İlgili konular