kafka-producer-api

3Hitze

4Antwort

Ich möchte Kafka in unserer Produktionsumgebung verwenden. Ich möchte wissen, ob die neueste Version des Clients für den Start der Produktion fehlerfrei ist. Arbeitet es mit der Verbrauchergruppe zusa

5Hitze

3Antwort

Kafka 0.10 Java Client TimeoutException: Batch enthält 1 Satz (e) abgelaufen

Ich habe einen einzigen Knoten, multi (3) Broker Zookeeper/Kafka-Setup. Ich benutze den Kafka 0.10 Java Client. Ich schrieb einfache Fern folgenden (auf einem anderen Server als Kafka) Produzent (im C

0Hitze

2Antwort

Wie finde ich den Offset-Bereich für eine Topic-Partition in Kafka 0.10?

Ich benutze Kafka 0.10.0. Vor der Verarbeitung möchte ich die Größe der Datensätze in einer Partition wissen. In Version 0.9.0.1 habe ich den Unterschied zwischen latest und earliest Offset für eine P

6Hitze

1Antwort

Kafka Produzent ist nicht in der Lage, Metadaten nach einiger Zeit zu aktualisieren

Ich habe eine Kafka-Umgebung, die 3 brokers und 1 zookeeper hat. Ich hatte in meinem Thema> 20K Nachricht gedrängt. Apache Storm berechnet die Daten in einem Thema, das vom Produzenten hinzugefügt wir

5Hitze

1Antwort

Kafka Consumer Poll() -Methode wird blockiert

Ich bin neu in Kafka 0.9 und testen einige Funktionen, die ich ein seltsames Verhalten in der Java-implementiert Consumer (KafkaConsumer) realisiert. Der Kafka-Broker befindet sich in einem externen G

2Hitze

1Antwort

Auf Kafka-Konsole nicht in der Lage, Nachricht mit einer Größe von mehr als 4095 Zeichen eingeben

Ich versuche, Nachricht über Kafka-Konsole Hersteller zu senden. Ich kann jedoch keine Nachrichten mit mehr als 4095 Zeichen eingeben. Versucht zu suchen, ob es eine Eigenschaft in Bezug auf Herstelle

0Hitze

1Antwort

Kann kafka Thema produzieren auch nach ACL Konfiguration

ich Kafka völlig neu bin und ich brauche für ein Thema konfiguriert ACL und ich habe unten versucht: - ./kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 \ --add --allow-principa

15Hitze

4Antwort

Wie überprüft man, ob Kafka Server läuft?

Ich möchte sicherstellen, ob der kafka Server läuft oder nicht, bevor Sie Produktions- und Verbrauchsjobs starten. Es ist in Windows-Umgebung und hier ist mein kafka Servers Code in Eclipse ... Proper

6Hitze

4Antwort

Kafka Consumer - Umfrageverhalten

Ich habe einige ernste Probleme, eine Lösung für meine Bedürfnisse zu implementieren, in Bezug auf KafkaConsumer (> = 0.9). Stellen wir uns vor, ich habe eine Funktion, die nur n Nachrichten von einem

3Hitze

1Antwort

Wie kann ich Daten von MySQL zum Kafka-Produzenten bringen?

Ich bin ein frischer in Big Data. Ich habe eine Datenbank in MySQL und ich weiß nicht, wie man dies in Apache Kafka für den Streaming-Prozess importiert. Und dann erhalten Daten vom Verbraucher. Bitte