Kafka Topic Partition Offset-Position immer von 0 oder Zufallswert und Wie sicher der Consumer-Datensatz ist der erste Datensatz in der Partition? Gibt es einen Weg, das herauszufinden? Bitte lass es mich wissen. Vielen Dank.Kafka Topic Partition
Antwort
Ja, Kafka-Offset beginnt bei 0 und endet mit der Bytelänge des vollständigen Datensatzes. Der nächste Datensatz wählt dann den Offset von dort aus.
Da Kafka vertrieben wird, können wir nicht garantieren, dass der Verbraucher die Daten in geordneter Weise erhält.
Bitte lesen Sie http://kafka.apache.org/documentation.html, um zu finden * Kafka hat auch stärkere Bestellgarantien als ein herkömmliches Nachrichtensystem. * Wenn wir über nicht bestellte Nachrichten sprechen, dann liegt das nicht an der Verteilung, sondern eher an der Partitionierung, würde ich sagen. – Harald
Wenn wir über Consumer sprechen, ist es nicht notwendig, dass alle Daten geordnet am Ziel ankommen. – Bector
Ja und nein.
Wenn Sie ein neues Thema beginnen, beginnt der Offset bei Null. In Abhängigkeit von der Kafka-Version Sie verwenden, sind die Offsets
- logische – und erhöht Nachricht von Nachricht (seit 0.8.0: https://issues.apache.org/jira/browse/KAFKA-506) – oder
- physikalische – dh der Offset erhöht durch die Anzahl der Bytes für jede Nachricht.
Darüber hinaus werden alte Protokolleinträge durch konfigurierbare Bedingungen gelöscht:
- Retentionszeit: zB Nachricht der letzten Woche halten nur
- Aufbewahrungsgröße: zB bei max 10 GB Speicher verwenden; Löschen Sie alte Nachrichten, die nicht mehr
- Log-Verdichtung gespeichert werden können (seit 0.8.1): Sie können nur den letzten Wert für jeden Schlüssel erhalten (siehe https://cwiki.apache.org/confluence/display/KAFKA/Log+Compaction)
Somit versetzt die erste nicht sein könnte Null wenn alte Nachrichten gelöscht wurden. Wenn Sie die Protokollkomprimierung aktivieren, fehlen außerdem einige Offsets.
In jedem Fall können Sie immer sicher nach einem Offset suchen, da Kafka herausfinden kann, ob der Offset gültig ist oder nicht. Bei einem ungültigen Offset wird automatisch zum nächsten gültigen Offset gesprungen. Wenn Sie also versuchen, Null zu versetzen, erhalten Sie immer die älteste Nachricht, die gespeichert wird.
- 1. Kafka Topic Partition und Spark Executor Mapping
- 2. Kafka Topic Alias
- 3. kafka Get Partition Anzahl für ein Thema
- 4. Kafka: Partition von ungültigem Broker verschieben
- 5. Wie finde ich den Offset-Bereich für eine Topic-Partition in Kafka 0.10?
- 6. PartitionId in kafka repliziert Partition
- 7. Kafka Thema vs Partition Thema
- 8. Abbrechen kafka Partition Aktion zuweisen
- 9. Kafka 0.8.2.1 Wie liest man aus __consumer_offsets topic
- 10. Scala - Tweets abonnieren - Kafka Topic und Ingest in HBase
- 11. Kafka: Wie erreichen Round Robin Partition in Kafka
- 12. Kafka gibt NoSuchElementException
- 13. Apache Kafka - KafkaStream auf Thema/partition
- 14. Kafka mehrere Verbraucher für eine Partition
- 15. Wie kafka Topic Namen und entsprechende Datensätze in Spark-Streaming-
- 16. Wie kafka Produzent Thema mit mehr als einer Partition mit Spring Integration kafka konfigurieren
- 17. Kafka Partition Rebalancing (Zuordnung) dauert zu viel Zeit
- 18. kafka-python - Wie stelle ich eine Partition fest?
- 19. DCOS/Mesos Kafka-Befehl zum Vergrößern der Partition
- 20. kafka multi-partition nur einer kann Nachricht empfangen
- 21. Wie wird man spätestens nach einem kafka Thema für eine Partition Offset?
- 22. Fehler beim Veröffentlichen der Nachricht zu Kafka Thema
- 23. AssertionError: Nicht zugeordnete Partition
- 24. spring-integration-kafka config consumer zum Empfangen der Nachricht von der Partition angeben
- 25. kafka NoClassDefFoundError kafka/Kafka
- 26. Kafka Broker vs Thema
- 27. Erstellen Sie einen Kafka Broker-Cluster mit Apache Kafka 0.10.0 API mit Java
- 28. Wie bekomme ich alle Nachrichten von kafka topic und zähle sie mit Java? manchmal
- 29. Wie kann ich ein Mock Kafka Topic für Junit-Tests instanziieren?
- 30. Sandcastle Topic Grouping
Was sind Ihre spezifischen Zweifel? Die Dokumentation besagt eindeutig: "Jede Partition ist eine [...] geordnete Folge von Nachrichten" (Suche nach "Bestellung" auf http://kafka.apache.org/documentation.html). Sind Sie sich bei der Bestellung unsicher oder möchten Sie den Verbraucher beim zweiten oder dritten Mal neu positionieren? – Harald