Simple Kafka Consumer Beispiel funktioniert nicht

Question

Simple Kafka Consumer Beispiel funktioniert nicht

8

Ich habe eine einfache Klasse, um Nachrichten von einem Kafka-Server zu konsumieren. Die meisten Codes werden aus den Kommentaren von org.apache.kafka.clients.consumer.KafkaConsumer.java kopiert.

%Vor%

Ich benutze 'org.apache.kafka: kafka-clients: 0.8.2.0'. es löst Ausnahme

aus %Vor%

Wie sollte ich den key.deSerializer konfigurieren?

java apache-kafka

David 31.07.2015, 11:59

quelle

3 Antworten

Tags und Links java apache-kafka

Django: Verwenden von Annotate, Count und Distinct in einem Queryset ejs, wie Objekt zu iterieren

score 10 · Answer 1

10

Dies funktioniert sofort, ohne eigene Serialisierer zu implementieren

%Vor%

Slavek Tecl 30.10.2015 18:13

quelle

score 2 · Answer 2

2

Sie haben es mit dem Byte-Array für Schlüssel- und Wertparameter zu tun. Also Byte-Serializer und Deserializer erforderlich.

Sie können Eigenschaften hinzufügen,

Zum Deserialisieren

%Vor%

Für Serialisierung

%Vor%

Vimal Dhaduk 16.11.2016 12:23

quelle

score 1 · Answer 3

Sie müssen die Eigenschaften festlegen:

%Vor%

in Ihrer Hauptmethode, damit Sie sie an den Konstruktor des Produzenten übergeben. Natürlich müssten Sie die richtigen Encoder angeben. Die Serializer-Klasse konvertiert die Nachricht in ein Bytearray und die key.serializer-Klasse wandelt das Schlüsselobjekt in ein Bytearray um. Im Allgemeinen haben Sie auch die Möglichkeit, den Prozess umzukehren.