apache-kafka

2Hitze

1Antwort

Gibt es eine Beschränkung der Anzahl der Gruppen, die ein Kafka haben sollte? Sagen wir, ein Benutzer fügt einen Kommentar für einen Beitrag hinzu. Daher wollte ich für jeden Beitrag eine Gruppe erste

1Hitze

1Antwort

Maximale Anzahl von Nachrichten, die in einer Kafka-Themenpartition gespeichert werden können?

Ich habe eine Aufbewahrungsrichtlinie für 48 Stunden festgelegt. So alte Protokolle werden schließlich gelöscht. Aber die Offset-Nummer des Themas wächst weiter. Wann wird diese Nummer zurückgesetzt?

0Hitze

1Antwort

C++ - kafka-client (rdkafka)

Ich verwende C++ kafka Implementierung von C++ rdkafka. Die Frage ist über RdKafka :: KafkaConsumer. Wie kann ich den Verbraucher so einstellen, dass er am Anfang eines Themas beginnt? P.S. Der Verbra

0Hitze

1Antwort

Kafka Consumer keine Daten konsumieren

Ich bin neu bei Kafka.Ich teste Kafka mit zwei Instanz von Tierpfleger und zwei Instanz von Broker.Ich erstellte ein Testthema "topicA". Es folgt die Beschreibung meines Themas. Topic:topicA Partition

-1Hitze

1Antwort

Abrufen der Website-Protokolle mit Apache Kafka und Bearbeiten mit Spark Streaming

Ich bin neu bei Apache Kafka.Ich konnte Konsolenhersteller und -verbraucher ausführen, aber jetzt möchte ich die Protokolle der Website meines Freundes mit Apache Kafka und Spark Streaming verarbeiten

0Hitze

1Antwort

Ist es möglich, 2Topics mit derselben Partition zu erstellen?

Meine Anforderung besteht darin, 2 Themen mit der gleichen Partition zu erstellen und wenn ich Nachrichten zu zwei verschiedenen Themen produzieren Daten in nur einer Partition speichern können. Ist e

1Hitze

1Antwort

Sollte ich meinen Node-Kafka-Consumer auf OffsetOutOfRange stoppen?

Ich schrieb einen Knoten-Kafka-Verbraucher. In seltenen Fällen starte ich den kafka-Client mit einer Gruppen-ID, die verwendet wurde, als bestimmte Offsets verfügbar waren, aber nicht mehr verfügbar s

-1Hitze

1Antwort

Was ist das Kafka? Ist es ein Datenspeicherserver?

Ist Kafka ein Datenspeicherserver? wie ich sie verstehe, in Beispiel Ein Benutzer kaufte ein Element im Spiel-Client. Spiel-Server speichert das Kaufprotokoll. Und der Game-Server die Daten an kafka S

2Hitze

1Antwort

kafka-console-producer und bash script

Möchten Sie eine Nachricht per Bash-Skript senden. bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 & sleep 2 bin/kafka-server-start.sh config/server.properties > serv

3Hitze

2Antwort

Wie Kafka Nachrichten mit Avro und Flink zu entschlüsseln

Ich versuche AVRO Daten aus einem Kafka Thema mit Flink 1.0.3 zu lesen. Ich weiß nur, dass dieses spezielle Kafka-Thema AVRO codierte Nachricht hat und ich habe die AVRO-Schemadatei. My Flink code: pu