kafka-producer-api

0Hitze

1Antwort

Nicht zu Kafka Broker zu produzieren java.nio.BufferUnderflowException

Ich bin in der Lage, Nachrichten von der kafka-console-producer.sh zu produzieren, aber der Java-Client ist nicht in der Lage, mit der unten genannten Ausnahme zu produzieren. mit Java 7, Kafka Versio

0Hitze

1Antwort

Kafka Datenverlust, in Hersteller

Ich habe versucht, einen Kafka-Broker, ein Thema, einen Produzenten, einen Verbraucher zu konfigurieren. wenn Produzent produziert, wenn der Broker nach unten geht, Datenverlust passiert, zB: In Buffe

0Hitze

1Antwort

Fehler beim Schreiben auf HDFS mit Kafka HDFS Connect

Ich versuche, Daten im AVRO-Format von meinem Java-Code zu Kafka HDFS mit kafka HDFS-Anschluss schreiben und ich bekomme einige Probleme. Als ich das einfache Schema und die Daten auf der konfluenten

1Hitze

3Antwort

Kafka: Wie erreichen Round Robin Partition in Kafka

Ich bin neu in kafka. Meine Anforderung ist, ich habe zwei Partitionen zum Beispiel Partition-0 und Partition-1 und ich habe eine Liste von Werten, die auch KEY-Wert enthält. Ich möchte Daten nach mei

1Hitze

1Antwort

Apache Kafka: Produzent produziert nicht alle Daten

Ich bin neu in kafka. Meine Anforderung ist, ich habe zwei Tabellen in der Datenbank Quelle und Ziel. Jetzt möchte ich Daten aus der Quellentabelle abrufen und sie zwischen den Kafkas speichern, damit

0Hitze

1Antwort

Ist es möglich, 2Topics mit derselben Partition zu erstellen?

Meine Anforderung besteht darin, 2 Themen mit der gleichen Partition zu erstellen und wenn ich Nachrichten zu zwei verschiedenen Themen produzieren Daten in nur einer Partition speichern können. Ist e

-1Hitze

1Antwort

Was ist das Kafka? Ist es ein Datenspeicherserver?

Ist Kafka ein Datenspeicherserver? wie ich sie verstehe, in Beispiel Ein Benutzer kaufte ein Element im Spiel-Client. Spiel-Server speichert das Kaufprotokoll. Und der Game-Server die Daten an kafka S

4Hitze

1Antwort

Kann keine Nachricht an Kafka von Dienst im Docker

Ich habe einen Rest-Service im Docker-Container auf Port 5000 ausgeführt, die verwendet wird, um Nachricht über Kafka Thema aus Docker Container zu produzieren. Ich habe meinen Produzenten Client mit

1Hitze

1Antwort

Apache kafka: wie programmatisch der Unterschied zwischen Warteschlange und Pub/Sub zu finden ist

Wie den Unterschied zwischen Warteschlange und Pub/Sub in einer programmatischen Weise kennen und mein Projekt Warteschlangen-Konzept erfordert. können Sie bitte ein Beispiel Queue-Programm in Java zu

1Hitze

3Antwort

NoBrokersVerfügbar: NoBrokersAvailable-Kafka Fehler

Ich habe bereits begonnen, Kafka zu lernen. Grundlegende Operationen darauf versuchen. Ich bin auf einen Punkt gestoßen, der über die "Broker" spricht. Mein Kafka läuft, aber wenn ich eine Partition e