Kafka löst java.nio.channels.ClosedChannelException aus

8

Wenn ich versuche, Nachrichten vom kafka-Server, der in ec2 gehostet wird, mit dem kafka console tool zu konsumieren (V 0.9.0.1, glaube ich, dass dies alte Consumer-APIs verwendet) Ich bekomme folgende Ausnahme. Wie kann ich das überwinden?

#. / kafka-console-consumer.sh --zookeeper zookeeper1.xx.com:2181 --topic MY_TOPIC --von Anfang an

%Vor%     
Ratha 06.04.2016, 04:58
quelle

2 Antworten

5

Der Grund für die ursprüngliche Closed-Channel-Ausnahme ist, dass ich ein DNS-Problem hatte, das ich durch Bearbeiten meiner lokalen Hosts-Datei gelöst habe

    
Ratha 06.04.2016, 06:47
quelle
1

Dies ist eigentlich eine Warnung - keine große Sache. Kann dein Thema beschädigt sein? Versuchen Sie, das Thema neu zu erstellen.

    
ponkin 06.04.2016 06:02
quelle

Tags und Links

Django: Verwenden von Annotate, Count und Distinct in einem Queryset json.net - wie man die Eigenschaft $ type NUR für das root-Objekt hinzufügt