Tag: kafka-producer-api

Bin ich immer diese Fehlermeldung beim ausführen von meinem Produzenten Klasse in Eclipse: org.apache.kafka.common.config.ConfigException: Fehlt die erforderliche Konfiguration "bootstrap.Server", die hat keinen Standardwert Hier ist mein producer-Klasse: public class SimpleProducer { public static void main(String args) throws

wenn ich den folgenden Befehl mit kafka 0.9.0.1 bekomme ich diese Warnungen[1]. Können Sie mir bitte sagen, was ist falsch mit meinen Themen? (Ich spreche auf die kafka-broker, die in ec2) #./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic MY_TOPIC?

Meinem Apache Kafka producer (0.9.0.1) zeitweise wirft einen org.apache.kafka.common.errors.NotLeaderForPartitionException Meinen code ausführt, die die Kafka senden Sie ähnelt dieser final Future<RecordMetadata> futureRecordMetadata = KAFKA_PRODUCER.send(new ProducerRecord<String, String>(kafkaTopic, UUID.randomUUID().toString(), jsonMessage)); try { futureRecordMetadata.get(); } catch (final InterruptedException interruptedException) {

Wenn ich versuche, Sie zu konsumieren Nachrichten aus der kafka-server, die gehostet wird in ec2 mit kafka-console (V 0.9.0.1 , ich denke, das nutzt alte Verbraucher-APIs) Ich bekomme folgende exception. Wie kann ich das umgehen? #./kafka-console-consumer.sh --Tierpfleger

Ich bin auf der Suche nach Aufklärung über das Thema. In Kafka-Dokumentationen habe ich Folgendes gefunden: Kafka stellt nur eine totale Ordnung über Nachrichten innerhalb einer partition, nicht zwischen verschiedenen Partitionen in ein Thema. Pro-partition Bestellung in

Ich bin neu auf Kafka und versuchen, setup-Umgebung für Sie . Ich versuche zu laufen, die einen einzelnen Knoten Kafka, aber ich bin immer Fehler in diesem. Folgenden folgenden Schritte auf mac 1. brew install zookeeper 2.

Wunderte ich mich über das, was Arten von Daten, die wir haben könnten, in Kafka-Themen. Wie ich weiß, im application-level-dies ist ein Schlüssel-Wert-Paaren, und dies könnte die Daten geben, die unterstützt wird durch die Sprache. Zum Beispiel

Habe ich die Schaffung einer einfachen, Kafka Producer & Consumer.Ich bin mit kafka_2.11-0.9.0.0. Hier ist mein Erzeuger-code, public class KafkaProducerTest { public static String topicName = "test-topic-2"; public static void main(String args) { //TODO Auto-generated method stub

Ich habe setup eine kafka Tierpfleger und 3 Broker auf einer Maschine, die auf ec2 mit ports 9092..9094 und versuche zu verbrauchen, das Thema von einer anderen Maschine. Die ports 2181 (zk), 9092, 9093 und 9094 (Server)

Was ist der Unterschied zwischen den unter zwei Abhängigkeiten? Brauche ich wirklich die erste, die ein Verbraucher oder Produzent app? <dependencies> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.9.2</artifactId> <version>0.8.2.1</version> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.8.2.1</version> </dependency> </dependencies> Mein Produzent funktioniert nur mit

Ich bin neu auf Kafka, Serialisierung und JSON - Was ich will, ist den Hersteller zu senden, eine JSON-Datei über kafka und die Verbraucher konsumieren und die Arbeit mit dem JSON-Datei in der ursprünglichen Datei-form. War ich

Will ich mit kafka auf unserer Produktionsumgebung. Ich möchte wissen, ob die neueste version der client ist bug-frei für Produktion starten. Ist es die Arbeit mit consumer group? Möchte ich weitergeben 10000 Datensätze pro Sekunde, ist es

Ich versuche, das laden einer einfachen text-Datei statt von der Standardeingabe in Kafka. Nach dem Download Kafka, habe ich folgende Schritte ausgeführt: Begann Tierpfleger: bin/zookeeper-server-start.sh config/zookeeper.properties Server Gestartet bin/kafka-server-start.sh config/server.properties Erstellt ein Thema mit dem Namen "test":