Suchergebnisse für Anfrage "kafka-producer-api"
Kafka-Themen und Partitionen verstehen
Ich fange an, Kafka für Unternehmenslösungszwecke zu lernen. ährend meiner Lesungen kamen mir einige Fragen in den Sin Wenn ein Produzent eine Nachricht erstellt - wird das @ angegebThem Es möchte die Nachricht an senden, ist das richtig? ...
NoBrokersAvailable: NoBrokersAvailable-Kafka Error
ch habe bereits angefangen, Kafka zu lernen. Probieren Sie grundlegende Operationen aus. Ich habe an einem Punkt festgehalten, der sich mit den "Brokern" befasst. Meine Kafka läuft, aber wenn ich eine Partition erstellen möchte. from kafka ...
Kafka Bestellung mehrerer Partitionen
Mir ist bekannt, dass es nicht möglich ist, mehrere Partitionen in Kafka zu bestellen, und dass die Partitionsreihenfolge nur für einen einzelnen Consumer innerhalb einer Gruppe (für eine einzelne Partition) garantiert ist. Aber ist es jetzt mit ...
Kafka 0.8.2.2 - Nachrichten können nicht veröffentlicht werden
Wir haben einen Java-Client für die Veröffentlichung von Nachrichten an kafka geschrieben. Der Code ist wie unten gezeigt Properties props = new ...
Kann keine Nachricht an kafka aus dem Dienst erzeugen, der im Docker ausgeführt wird
Ich habe einen Rest-Service im Docker-Container auf Port 5000, der verwendet wird, um eine Nachricht über ein kafka-Thema zu erstellen, dessen Docker-Container leer ist. Ich habe meinen Produzenten-Client mit den folgenden ...
Kafka 0.9.0.1 Java Consumer bleibt in awaitMetadataUpdate () hängen
Ich versuche, einen einfachen Kafka-Konsumenten mit der Java-API v0.9.0.1 zum Laufen zu bringen. Der von mir verwendete Kafka-Server ist ein Docker-Container, auf dem auch Version 0.9.0.1 ausgeführt wird. Unten ist der Verbrauchercode: public ...
Kafka 0.10 Java Client TimeoutException: Stapel mit 1 Datensatz (en) abgelaufen
Ich habe einen einzigen Knoten, Multi (3) Broker Zookeeper / Kafka-Setup. Ich verwende den Kafka 0.10 Java-Client. Ich habe folgenden einfachen Remote-Produzenten (auf einem anderen Server als Kafka) geschrieben (in dem Code, den ich durch MYIP ...
Kafka: Ändere die Anzahl der Partitionen für ein bestimmtes Thema mit java
Ich bin neu bei Kafka und arbeite mit dem neuen KafkaProducer und KafkaConsumer, Version: 0.9.0.1. Ist es in Java möglich, die Anzahl der Partitionen für ein bestimmtes Thema zu ändern / zu aktualisieren, nachdem es erstellt wurde. Ich benutze ...
Wie konfiguriere ich die Protokollierung für Kafka-Produzenten?
Ich verwende Kafka Producer Client und ich habe keine log4j-Konfiguration in meinem Projekt. Wenn es läuft, druckt das Programm eine Menge Kafka Debug-Protokolle, die ich wirklich nicht möchte. Also, ich habe versucht, eine log4j.properties ...