/ / Jak robi (powinien) Kafka radzi sobie z komunikatami trucizny - apache-kafka, kafka-consumer-api

W jaki sposób (powinien) Konsument Kafki radzi sobie z komunikatami o truciznach - apache-kafka, kafka-consumer-api

Kiedy konsument Kafka nie zdesrializuje wiadomości, czy to aplikacja kliencka jest odpowiedzialna za obsługę wiadomości trucizny?

Lub

Czy Kafka „zwiększa” przesunięcie wiadomości i kontynuuje korzystanie z ważnych wiadomości?

Czy istnieje „najlepsza praktyka” do radzenia sobie z komunikatami trucizny w tematach Kafki?

Odpowiedzi:

2 dla odpowiedzi № 1

Gdy Kafka nie jest w stanie dokonać deserializacji rekordu, konsument otrzyma org.apache.kafka.common.KafkaException, powinieneś sam popełnić przesunięcie i nadal konsumować.

Powiązane pytania

Jak odsłonić serwis konsumencki dla kafka jako ciągłego słuchacza - wiosna, cxf, wiosenna integracja, apache-kafka, kafka-consumer-api
Spark Streaming z Kafką w Scali - scala, apache-spark, apache-kafka
Apache Kafka, węzeł js i przepływ pracy punkt-punkt - node.js, apache-kafka, kafka-consumer-api
Kafka - Tworzenie grupy konsumentów z określonym przesunięciem? - java, apache-zookeeper, apache-kafka, kafka-consumer-api
Sprawdź, czy kolejka Kafki jest pusta - clojure, apache-kafka, clj-kafka
Zookeeper: Jak korzystać z Konsumenta wysokiego poziomu, aby znaleźć listę brokerów kafka - apache-zookeeper, apache-kafka
Przerwa po stronie konsumenta Kafki i ponowna dostawa - apache-kafka, kafka-consumer-api, wiosenna kafka
konsument kafka w skrypcie powłoki - apache-kafka, kafka-consumer-api
Dystrybucja logów Kafka wśród konsumentów - apache-kafka, kolejka wiadomości
Kafka 0.10.1.0 zmiana czasu przesunięcia - apache-kafka, offset, konsument
Mapowanie partycji Kafki na Kafkę Konsument / Grupa konsumencka - apache-kafka, kafka-consumer-api
Kafka: Błąd od SyncGroup, Upłynął limit czasu żądania - apache-kafka, kafka-consumer-api
Kafka consumer api (bez konfiguracji zookeepera) - apache-kafka
Czy kafka ma górny limit na ilu klientów może obsługiwać? - apache-kafka, kafka-consumer-api, kafka-producent-api
Konsument Kafka nie zużywa wiadomości ze wszystkich partycji - apache-kafka, kafka-consumer-api
Jak powiadomić producenta w kafka? - apache-kafka
jak uruchomić program kafka programowo - apache-kafka, spring-kafka
Kafka jak spożywać wiele tematów równolegle - apache-kafka, konsument, kafka-konsument-api
rebalancing przegrody kafki (przydziału) zajmuje zbyt dużo czasu - apache-kafka, kafka-consumer-api, kafka-producer-api
Konsument Pauza i wznowienie działa na poziomie ConsumerGroup? - apache-kafka, kafka-consumer-api