apache-kafka

1Hitze

1Antwort

Offset und Verzögerung für kafka Verbraucher (über neue Verbraucher api erstellt) werden auf unbekannte

ich oft Problem sehe, in dem KAFKA Verbraucherstrom wird versetzt und Verzögerung zu unbekannt Frühere Verbraucher gesetzt kompensiert haben und Lag GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OF

0Hitze

1Antwort

Warum werden alle Elemente gedruckt, obwohl sie in mapWithState identisch sind

Ich sende 3 Mal das gleiche Objekt an JavaPairDStream. Ich aktualisiere seinen Zustand, aber es ist 3 mal gespeichert. Das Drucken von JavaPairDStream bestätigt dies. Function3<InputMessageKey, Option

0Hitze

2Antwort

Kafka Consumer (neue Consumer API) läuft für immer

Ich habe ein Warteschlangensystem auf Apache Kafka gebaut. Die Anwendung wird Nachrichten an bestimmte Kafka topic produzieren und auf der Verbraucherseite muss ich alle Datensätze zu dem Thema produz

0Hitze

1Antwort

Ausführungsplan Vorlagen in Wso2 CEP

Ich verwende WSO2 CEP für die Verarbeitung der Ereignisse aus einem Kafka-Thema. Ich möchte dies auf mehrere kafka-Themen verallgemeinern, die Protokolle in einem ähnlichen Format speichern, d. H. Jed

0Hitze

1Antwort

SASL-Authentifizierung fehlgeschlagen Anmeldekontext 'Client' mit

ich bei der Sicherung Kafka mit Kerberos in CDH 5.5 Kafka Version arbeite: 2.0.1 Kerberos aktiviert ist und funktioniert gut wenn ich sasl in kafka mit cloudera maneger ermöglichen , erhalte ich die F

0Hitze

1Antwort

Wie Kafka Verbraucher Zustand zu überprüfen

Ich habe Kafka High-Level-Verbraucher. public class KafkaHighLevelConsumer implements Runnable { private final KafkaConsumer<String, String> consumer; private final List<String> topics;

4Hitze

1Antwort

kafka-console-producer.sh TimeOutException

Ich versuche Nachrichten mit dem Kafka-Konsolenproduzenten an einen Kafka-Broker zu senden, der auf demselben Rechner läuft. Als ich echo "Hello world" | ./kafka-console-producer.sh --broker-list loca

3Hitze

3Antwort

Kafka Streams: Wie schreibe ich zu einem Thema?

In Kafka Streams, was ist der kanonische Weg, einen Stream zu produzieren/zu schreiben? In Spark gibt es den benutzerdefinierten Empfänger, der als ein lang laufender Adapter aus einer beliebigen Date

1Hitze

2Antwort

Kafka Consumer nicht konsumieren

Hier ist mein Code für den Aufbau eines Kafka-Consumer aus dem Java-Client. def buildConsumer[Key, Value]( configuration: KafkaConfiguration, commitInterval: Long, groupId: Option[String] = None)(

1Hitze

2Antwort

Rückspulversatz für Spring Integration Kafka consumer

Gibt es eine Möglichkeit, den Offset des Kafka-Verbrauchers über spring-integration-kafka zurückzuspulen? Ich möchte etwas wie die --from-beginning Option, die mit Kafka-Konsole Consumer-Skript verwen