schreiben Avro-Daten zu Kafka mit Python

Ich benutze 'Confluent-Kafka-Python'client, Avro-Daten zu einem Kafka-Thema zu schreiben.schreiben Avro-Daten zu Kafka mit Python

Ich habe die Daten geschrieben, aber wenn ich versuche, die Daten zu lesen mit: kafkas-Avro-console-Verbraucher bekomme ich einen Fehler:

[2017-05-02 13:38:11,387] ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:105) 
org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 4 
Caused by: java.net.ConnectException: Connection refused (Connection refused) 
     at java.net.PlainSocketImpl.socketConnect(Native Method) 
     at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) 
     at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) 
     at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) 
     at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) 
     at java.net.Socket.connect(Socket.java:589) 
     at java.net.Socket.connect(Socket.java:538) 
     at sun.net.NetworkClient.doConnect(NetworkClient.java:180) 
     at sun.net.www.http.HttpClient.openServer(HttpClient.java:463) 
     at sun.net.www.http.HttpClient.openServer(HttpClient.java:558) 
     at sun.net.www.http.HttpClient.<init>(HttpClient.java:242) 
     at sun.net.www.http.HttpClient.New(HttpClient.java:339) 
     at sun.net.www.http.HttpClient.New(HttpClient.java:357)

offenbar kann er die Daten nicht entschlüsseln. irgendwelche Ideen?

Quelle

2017-05-02 bsd

Sieht so aus, als könnte es keine Verbindung zur Schema-Registrierung herstellen. Sind Sie sicher, dass Sie den Dienst eingerichtet haben und die URL und die Port-Verbindung für Ihre Kunden herstellen?

Versuchen Hinzufügen Folgendes zu Ihrer Konsole Verbraucher

--Eigentum schema.registry.url = Adresse Ihres Schema Registry

Quelle

2017-05-03 02:37:53

Ich bekomme den gleichen Fehler, auch wenn ich zu einem Thema suchen Landloop verwenden. Es wird anerkannt, dass Avro ist, aber wenn ich das Thema wählen erhalte ich: { "error_code": 50002, "message": "Kafka Fehler: Fehler Avro Nachricht für id Deserialisieren 13" } – bsd

ich hinzugefügt haben --property schema.registry.url und es funktioniert. Vielen Dank ! – bsd

schreiben Avro-Daten zu Kafka mit Python

Antwort

Verwandte Themen