kafka-producer-api

Wird für Fragen verwendet, die sich auf die Apache Kafka Producer-API beziehen. Jede Frage im Zusammenhang mit Kafka-Themen. Herstellerfehler und Wiederherstellung, Idempotenz und Transaktions-API.
4
Antworten

Wie konfiguriere ich die Protokollierung für Kafka-Produzenten?

Ich verwende den Kafka Producer Client und ich habe keine log4j Konfiguration in meinem Projekt. Beim Ausführen druckt das Programm eine Menge Kafka Debug-Protokolle, die ich wirklich nicht will. Also habe ich versucht, eine log4j.properti...
03.03.2016, 13:40
6
Antworten

Fehler beim Veröffentlichen der Nachricht zum Kafka-Thema

Ich bin neu bei Kafka und versuche, dafür eine Umgebung einzurichten. Ich versuche, einen einzelnen Knoten Kafka zu betreiben, aber ich bekomme Fehler darin. Folge den Schritten auf dem Mac %Vor% Aber ich bekomme folgenden Fehler. Bitte l...
19.10.2015, 10:24
2
Antworten

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

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?...
06.04.2016, 04:58
1
Antwort

Kafka-Consumer konnte beim Abrufen von Themenmetadaten "Leader nicht finden"

Wenn ich versuche, das Skript Kafka Producer und Consumer (0.9.0) zu verwenden, um Nachrichten von einem Thema zu pushen / zu ziehen, erhalte ich die folgenden Fehler. Erzeugerfehler %Vor% Verbraucherfehler %Vor% Warum erhalte ich den...
13.01.2016, 03:19
1
Antwort

Wie fügt man eine Verbrauchergruppe zur Nachricht in Java hinzu?

Ich bin neu in Java, Frühling und Kafka Ich habe den nächsten Code zum Senden der Nachricht %Vor% Meine Konfiguration für den Hersteller: %Vor% Ich möchte eine Nachricht mit meiner Verbrauchergruppe (Beispiel "MyConsumerGroup"), senden...
26.01.2017, 09:53