kafka-producer-api

8Hitze

1Antwort

Kafka Consumer "konnte Leiter nicht finden" beim Abrufen von Thema Metadaten

Wenn ich versuche, das Kafka Producer und Consumer (0.9.0) Skript zu verwenden, um Nachrichten von einem Thema zu pushen/ziehen, erhalte ich die folgenden Fehler. Producer Fehler [2016-01-13 02:49:40,

8Hitze

6Antwort

Fehler beim Veröffentlichen der Nachricht zu Kafka Thema

Ich bin neu in Kafka und versuche, Umgebung dafür einzurichten. Ich versuche, einen einzelnen Knoten Kafka auszuführen, aber ich bekomme Fehler darin. Nach folgenden Schritte auf mac 1. brew install z

1Hitze

1Antwort

Kafka wirft java.lang.NoSuchMethodException

Ich habe meinen eigenen Serialiser geschrieben, um ein Java-Objekt zu einem Thema zu veröffentlichen. Ich habe die Eigenschaft serializer.class auf meinen benutzerdefinierten Serialiser gesetzt. Beim

0Hitze

2Antwort

PartitionId in kafka repliziert Partition

Ich implementiere Kafka Produzent mit einzelnen Thema mit mehreren Partitionen. Ich wähle, auf welche Partition eine Nachricht um einen bestimmten Wert (feedName Eigenschaftswert in Nachricht json) in

1Hitze

1Antwort

Wie kafka.consumer.ConsumerTimeoutException zu überwinden?

Ich benutze Kafka 2.11-Version, um einen Verbraucher zu schreiben. Ich bekomme ständig eine Timeout-Ausnahme. Ich bin nicht sicher, dass ich die richtigen APIs hier verwenden Kann mir jemand helfen? E

6Hitze

1Antwort

Konvertieren von pojos in generische Datensätze in confluent.io zum Senden über einen KafkaProducer

Ich bin komplett neu bei Kafka und avro und versuche, das konfluente Paket zu verwenden. Wir haben bestehende POJOs, die wir für JPA verwenden, und ich möchte einfach eine Instanz meiner POJOs erstell