it-swarm-eu.dev

apache-kafka

Kafka Consumer - Umfrageverhalten

Kafka Produzent TimeoutException: Läuft 1 Datensätze ab

Kafka Streams mit Spring Boot

Kafka: Consumer-API vs Streams-API

Wie verbinde ich Kafka mit Elasticsearch?

Unterstützt Kafka das Senden von Anforderungsantworten?

So erstellen Sie Themen in Apache Kafka

Kafka löst Java.nio.channels.ClosedChannelException aus

Spring Boot Kafka: Verbraucher kann aufgrund von NoSuchBeanDefinitionException nicht gestartet werden

Verstehen von Kafka Themen und Partitionen

Wie schreibe ich eine Datei an Kafka Producer

Wie erhalte ich den neuesten Offset für eine Partition für ein kafka topic?

Themen, Partitionen und Schlüssel

Fehler beim Veröffentlichen einer Nachricht im Kafka-Thema

Begrenzen Sie die Kafka-Stapelgröße, wenn Sie Spark Streaming verwenden

Kafka Connect geht der Speicherplatz aus

Kafka - Dieser Server ist nicht der Anführer dieser Themenpartition

Unterstützt Kafka Java 10 oder Java 11?

Kafka Connect Distributed-Modus Der Gruppenkoordinator ist nicht verfügbar

Umgang mit schlechten Nachrichten mit der Streams-API von Kafka

Wie kann ich das endgültige Ergebnis der Kafka-Streams-Aggregation einer zeitfenstergesteuerten KTable senden?

Fehler beim Erstellen des Kafka-Themas: - Replikationsfaktor größer als verfügbare Broker

Wie liest man Daten von Anfang an mit der Kafka Consumer API?

Wie benutze ich die Consumer API von Kafka 0.8.2?

Kafka - Implementierung der verzögerten Warteschlange unter Verwendung hoher Konsumenten

Kafka Serializer JSON

Letzte Nachricht aus dem Konsolenskript von kafka erhalten

Wie man kafka consumer dazu bringt, vom letzten verbrauchten Offset aber nicht vom Anfang an zu lesen

Kafka, wie man aus dem Thema __consumer_offsets liest

Verbraucher erhalten keine Nachrichten, Kafka-Konsole, neue Verbraucher-API, Kafka 0.9

Können mehrere Kafka-Konsumenten dieselbe Nachricht von der Partition lesen

Kafka Consumer Markieren Sie den Koordinator 2147483647 tot

Wie konfiguriere ich die Protokollierung für Kafka-Produzenten?

Wie kann man überprüfen, ob der Kafka Server läuft?

Kafka mit .Net Client

Kafka 0.10 Java Client TimeoutException: Stapel mit 1 Datensatz (en) abgelaufen

Wie kann ich den LETZTEN Versatz eines Kafka-Themas erhalten?

wie Sie den Gruppennamen festlegen, wenn Sie Nachrichten in kafka über die Befehlszeile verwenden

Kafka Getting error Keine auflösbaren Bootstrap-URLs in Bootstrap-Servern angegeben

iD der Verbrauchergruppe verstehen

Kafka-Bootstrap-Server vs. Zookeeper in Kafka-Konsolen-Konsumenten

Anzahl der Nachrichten, die in einem Kafka-Thema gespeichert sind

Nicht klar über die Bedeutung von auto.offset.reset und enable.auto.commit in Kafka

Wie speichert Kafka Offsets für jedes Thema?

Wie man den aktuellen Offset im Frühjahr kafka für manuelles Commit erkennt

Spring Kafka - Wie setze ich den Offset mit einer Gruppen-ID auf den neuesten zurück?

Spring Kafka Producer sendet nicht an Kafka 1.0.0 (Magic v1 unterstützt keine Datensatzheader)

Wie schreibt man Kafka-Konsumenten - Single-Threaded vs. Multi-Threaded

Führende Makler ohne passenden Listener-Fehler in Kafka

Einfaches eingebettetes Kafka Testbeispiel mit Spring Boot

Wird der Schlüssel zum Senden von Nachrichten an Kafka benötigt?

Kafka Verbraucherliste

Kafka Consumer-Abruf von Metadaten für Themen fehlgeschlagen

Kafka in Docker funktioniert nicht

Was bedeutet "Rebalancing" im Apache Kafka Kontext?

Spark Streaming - Lesen und Schreiben am Kafka Thema

Kafka und Firewall-Regeln

Unterschied zwischen session.timeout.ms und max.poll.interval.ms für Kafka 0.10.0.0 und spätere Versionen

Kafka Consumer erhält Schlüsselwertpaar

Kafka Standardgruppen-ID des Verbrauchers

Kafka10.1 heartbeat.interval.ms, session.timeout.ms und max.poll.interval.ms

Was ist der Unterschied zwischen kafka frühesten und spätesten Offsetwerten?

Kafka Konsolenkonsument FEHLER "Fehler beim Festschreiben des Versatzes auf Partition"

Warum geben Konsumenten nach dem Update auf 1.1 Kafka= INVALID_FETCH_SESSION_Epoch aus?

Löschen Sie die Nachricht nach dem Verzehr in KAFKA

Kafka Verbraucher für mehrere Themen

Testen eines @KafkaListener mit Spring Embedded Kafka

Apache Kamel gegen Apache Kafka

Klassenpfad ist leer. Bitte erstellen Sie zuerst das Projekt, z. durch Ausführen von './gradlew jar -PscalaVersion = 2.11.12'

Wie bekomme ich Daten vom alten Versatzpunkt in Kafka?

Gibt es eine Möglichkeit, vor einem Lauf alle Daten eines Themas zu löschen oder das Thema zu löschen?

Problem beim Rebalancing beim Lesen von Nachrichten in Kafka

Gibt es eine einfache Möglichkeit, Kafka unter Windows zu installieren?

Bei Verwendung von Kafka 0.8.1 mit Zookeeper in LeaderNotAvailableException laufen

Apache-Kafka-Fehler unter Windows - Hauptklasse QuorumPeerMain konnte nicht gefunden oder geladen werden

KafkaUtils-Klasse in Spark-Streaming nicht gefunden

Warum verbinden sich Kafka-Konsumenten mit Zoookeeper, und Produzenten erhalten Metadaten von Maklern?

Kafka kann keine Verbindung zu Zookeeper herstellen

Kafka auf Kubernetes Multi-Node

Fehler beim Ausführen von Kafka unter Windows

Spark-Streaming + Kafka: SparkException: Es konnten keine Leader-Offsets für Set gefunden werden

So beenden Sie das Spark-Streaming, wenn die Datenquelle aufgebraucht ist

Wie verwende ich Multi-Thread-Consumer in kafka 0.9.0?

fehler beim Starten des Kafka-Brokers

Wie lösche ich eine Kafka Consumer Group, um Offsets zurückzusetzen?

Alle Kafka-Themen auflisten

Kafka 1.0 wird mit dem FATAL SHUTDOWN-Fehler beendet. Protokollverzeichnis fehlgeschlagen

Kafka + Zookeeper: Die Verbindung zum Knoten -1 konnte nicht hergestellt werden. Der Broker ist möglicherweise nicht verfügbar

Sichern/Wiederherstellen von Kafka und Tierpfleger

Spark-strukturiertes Streaming in die Confluent-Schema-Registry integrieren

Wie starte ich den kafka Server richtig?

Ist Zookeeper ein Muss für Kafka?

Wie kann ich überprüfen, ob ZooKeeper ausgeführt wird oder über die Eingabeaufforderung gestartet wurde?

zookeeper ist keine anerkannte Option beim Ausführen von kafka-console-consumer.sh

Apache Kafka vs Apache Storm

Was sind die Vor- und Nachteile von Kafka gegenüber Apache Pulsar?

Wie erstelle ich ein Thema in Kafka bis Java

Fehler beim Lesen des Artefaktdeskriptors: IntelliJ

Kafka SASL-Zookeeper-Authentifizierung

Erhaltene KeeperException auf Benutzerebene bei der Verarbeitung