apache-kafka

1Hitze

1Antwort

Verwendung von Kafka mit mehreren Eingängen und einem einzigen Ausgang?

Wäre Kafka erforderlich, wenn mehrere Datenströme in einen zentralen Knoten gelangen, aber alle in Hadoop oder Spark verarbeitet werden müssen? Da die verschiedenen Arten von Informationen nicht gefil

2Hitze

3Antwort

Kafka Connect Api - Erste Schritte?

Ich möchte den Entwicklungslebenszyklus von Kafka Connect Modulen verstehen. Nach http://kafka.apache.org/090/documentation.html#connect möchte ich ein benutzerdefiniertes Kafka-Verbindungsmodul mit d

1Hitze

1Antwort

Kafka wirft java.lang.NoSuchMethodException

Ich habe meinen eigenen Serialiser geschrieben, um ein Java-Objekt zu einem Thema zu veröffentlichen. Ich habe die Eigenschaft serializer.class auf meinen benutzerdefinierten Serialiser gesetzt. Beim

0Hitze

2Antwort

PartitionId in kafka repliziert Partition

Ich implementiere Kafka Produzent mit einzelnen Thema mit mehreren Partitionen. Ich wähle, auf welche Partition eine Nachricht um einen bestimmten Wert (feedName Eigenschaftswert in Nachricht json) in

0Hitze

1Antwort

Wie Standard Kafka SpoutConfig Klasse ändern

Ich bekomme den Nachrichtenstrom von 3 MB von Kafka Thema, aber der Standardwert ist 1 MB. Jetzt habe ich die kafka-Eigenschaften von 1MB auf 3MB geändert, indem ich die folgenden Zeilen in die Dateie

2Hitze

2Antwort

kafka Verbraucher dynamisch Themen erkennen hinzugefügt

I KafkaConsumer bin mit Nachrichten von Kafka-Server (Themen) zu konsumieren .. Es funktioniert für Themen Fein erstellt vor Consumer-Code gestartet ... Aber das Problem ist, es wird nicht funktionier

2Hitze

1Antwort

Zookeeper oder Kafka Verbindung Fehler, Anzeigen Kazoo :: VersionNotSupported Fehler

Ich bin mit Kafka und Tierpfleger, und die Schaffung von Verbindung zwischen ihnen, aber die Verbindung wird immer wieder fallen gelassen und wieder, wenn ich versuche, neue Kafka erstellen :: Verbrau

3Hitze

1Antwort

Mesos DCOS installiert Kafka nicht

Ich versuche, Kafka auf Mesos zu installieren. Die Installation scheint erfolgreich verlaufen zu sein. [email protected]:/dcos$ dcos package install kafka This will install Apache Kafka DCOS Service.

1Hitze

1Antwort

Wie kafka.consumer.ConsumerTimeoutException zu überwinden?

Ich benutze Kafka 2.11-Version, um einen Verbraucher zu schreiben. Ich bekomme ständig eine Timeout-Ausnahme. Ich bin nicht sicher, dass ich die richtigen APIs hier verwenden Kann mir jemand helfen? E

0Hitze

1Antwort

Kafka, wie die neueste erstellte Partition ID für ein Thema in Java zu kennen ist

Ich erstelle Partition für ein Thema dynamisch mit AdminUtils. Ich muss die PartitionId der neu erstellten Partition abrufen, um sie in Mysql für meine Geschäftslogik zu speichern. Wie kann ich das er