kafka-consumer-api

4Hitze

3Antwort

kafka-python - Wie stelle ich eine Partition fest?

Verwenden von kafka-python-1.0.2. Wenn ich ein Thema mit 10 Partitionen habe, wie gehe ich über eine bestimmte Partition, während ich die verschiedenen Partitionen und Nachrichten durchlaufe. Ich kann

1Hitze

2Antwort

Kafka neuer Konsument: (re) setze und setze Offsets mit assign, not subscribe

Mit dem neuen Kafka Java consumer api führe ich einen einzigen Consumer aus, um Nachrichten zu konsumieren. Wenn alle verfügbaren Nachrichten verbraucht sind, töte ich sie mit kill -15. Jetzt möchte i

3Hitze

1Antwort

Was ist der beste Weg, verschiedene Arten von Nachrichten zu veröffentlichen und zu konsumieren?

Kafka 0,8V Ich mag/veröffentlichen verbrauchen byte [] Objekte, Java Bean Objekte, serialisierbare Objekte und vieles mehr .. Was ist der beste Weg, um einen Verleger und Verbraucher für diese zu defi

7Hitze

1Antwort

Avro-Decodierung gibt java.io.EOFException

Ich benutze Apache avro Schema mit Kafka 0.0.8V. Ich benutze das gleiche Schema bei Producer/Consumer-Enden. Es gibt NO ANY Änderungen im Schema. Aber ich bekomme eine Ausnahme beim Verbraucher, wenn

0Hitze

2Antwort

Was sind die Vor- und Nachteile der Schaffung Kafka Broker und Tierpfleger in zwei Docker Container in der gleichen Maschine

Ich erstelle eine Kafka-Datenpipeline mit 3 Kafka Broker und 3 Tierpfleger, also muss ich 6 Maschinen verwenden, 3 Broker und 3 zoekepers zu implementieren . Es gibt zwei Möglichkeiten keine/Maschinen

0Hitze

1Antwort

JBOSS gibt org.apache.kafka.common.KafkaException: auth.conf kann nicht gelesen werden

Wenn ich Krieg meiner einfachen Kafka-Projekt (das funktioniert wie ein Glas) in Wildfly v 10 bereitstellen, bekomme ich einige Zoo Keeper-Verbindung Ausnahme [ 1] .Diese tritt auf, wenn kafka Zuhörer

6Hitze

2Antwort

Gibt es eine Möglichkeit, die Nachrichtenreihenfolge zwischen Partitionen eines Kafka-Themas mit einem einzelnen Verbraucher zu verwalten?

Wir entwickeln ein kafka-basiertes Streaming-System, in dem der Produzent zu mehreren Partitionen innerhalb seines Themas produzieren würde und ein einzelner Konsument von dem Thema konsumieren würde.

0Hitze

1Antwort

Kafka-Produzent erstellt Thema, kann aber keine Nachrichten senden

Ich bin neu bei Scala und Kafka und habe Probleme bekommen. Ich versuche einen Scala Kafka Producer mit einem Kafka Server zu verbinden, der auf einem Cloudera Express Server installiert ist. Ich habe

2Hitze

1Antwort

Spring Integration kafka: org.apache.kafka.common.config.ConfigException während der Ausführung von Consumer

Ich habe versucht, Kafka-Verbraucher aus dem Code es immer Ausnahme ausführen, aber ich lief kafka-console-consumer.sh-Datei zu überprüfen, Hersteller es funktioniert gut und zeigt alle Nachrichten an

2Hitze

2Antwort

kafka Verbraucher Registrierungsliste in zoekeeper

Ich benutze C++ kafka lib zu produzieren/konsumieren Nachrichten mit Kafka - alles funktioniert gut. Jetzt möchte ich meinen Kunden überwachen, um Unterbrechungen/Fehler zu behandeln. Ich suche eine A