apache-kafka

9Hitze

5Antwort

So erstellen Sie ein Thema in Apache kafka mit Python

Bisher habe ich noch keinen Python-Client gesehen, der das Erstellen eines Themas explizit implementiert, ohne die Konfigurationsoption zum automatischen Erstellen der Themen zu verwenden.

10Hitze

1Antwort

kafka als Ereignisspeicher in ereignisbasiertem System

Diese Frage ähnelt Using Kafka as a (CQRS) Eventstore. Good idea?, aber mehr Implementierung spezifisch. Wie kafka als Ereignisspeicher zu verwenden, wenn ich Tausende von Ereignis "Quellen" (Aggregat

8Hitze

2Antwort

Apache Storm java.nio.channels.ClosedChannelException: null

Wir versuchen, Apache Storm für die Verarbeitung großer Mengen (gefälschter) Nachrichten zu verwenden. Nachricht Beispiel: "{"clientName":"Sergey Bakulin","sum":12925,"group":"property","suspicious":f

5Hitze

1Antwort

Kafka Java-Consumer funktioniert nur für localhost und schlägt für Remote-Server fehl

Ich arbeite seit zwei Monaten mit Kafka und habe diesen Code verwendet, um Nachrichten lokal zu konsumieren. Ich habe vor kurzem beschlossen, Zookeeper und Kafka zu verteilen und alles scheint gut zu

12Hitze

2Antwort

kafka-server-stop.sh funktioniert nicht, wenn Kafka vom Python-Skript gestartet wurde

Nach der Bereitstellung einiger Apache Kafka-Instanzen auf Remote-Knoten habe ich ein Problem mit dem Skript kafka-server-stop.sh im Kafka-Archiv beobachtet. standardmäßig enthält: #!/bin/sh # Licens

5Hitze

2Antwort

Sturm Nimbus nicht gestartet: Fehler unter

$ storm nimbus Traceback (most recent call last): File "/home/chefsolo/apache-storm-0.9.1-incubating/bin/storm", line 455, in <m odule> main() File "/home/chefsolo/apache-

5Hitze

1Antwort

Wie sollen wir die Kafka-Themen in einem bestimmten Zeitbereich lesen?

Ich muss die Nachrichten in einem bestimmten Zeitraum aus einem Kafka-Thema lesen. Die Lösung, die ich mir vorstellen kann, besteht darin, zuerst den größten Offset für den Anfang des Zeitbereichs her

5Hitze

2Antwort

Kamel Kafka Integration

Ich habe kürzlich festgestellt, dass Camel jetzt eine eigene Komponente für Kafka hat, also habe ich beschlossen, es zu drehen. beschloss ich, eine schöne einfache Datei, um zu versuchen -> kafka Them

11Hitze

6Antwort

So erhalten Sie Themenliste von Kafka-Server in Java

Ich verwende kafka 0.8 Version und sehr viel neues dazu. Ich möchte die Liste der Themen in kafka server zusammen mit seinen Metadaten erstellt wissen. Gibt es eine API, um das herauszufinden? Grundsä

8Hitze

1Antwort

WebSocket wird nach 1000 Nachrichten geschlossen

Ich schreibe eine App, um Nachrichten von Apache Kafka mit einem WebSocket an den Browser zu streamen. Wenn der Server Nachrichten für eine Weile nicht konsumiert und der Offset hinterherhinkt, schlie