/ / Яким чином (повинен) Кафка Споживач справляється з повідомленнями про отруєння - apache-kafka, kafka-consumer-api

Як (повинен) Кафка Споживач справлятися з отруйними повідомленнями - apache-kafka, kafka-consumer-api

Коли споживач Кафки не зможе десеріалізувати повідомлення, чи відповідальність клієнтських програм полягає в тому, щоб боротися з отруйним повідомленням?

Or

Чи Кафка «збільшує» зміщення повідомлення та продовжує споживати дійсні повідомлення?

Чи існує "Краща практика" для боротьби з отруйними повідомленнями, що проводяться на теми Кафки?

Відповіді:

2 для відповіді № 1

Коли Кафка не зможе десеріалізувати запис, споживач отримає a org.apache.kafka.common.KafkaException, ви повинні зробити зсув самостійно і продовжувати споживати.

Схожі запитання

Як виставити споживацьке обслуговування для кафки як безперервного слухача - spring, cxf, spring-integration, apache-kafka, kafka-consumer-api
Іскра потокує з Кафкою в Скалі - скала, апач-іскрі, апаше-кафка
Apache Кафка, вузол JS і робота «Точка-точка-точка» - node.js, apache-kafka, kafka-consumer-api
Кафка - Створення споживчих груп з певним зміщенням? - java, apache-zookeeper, apache-kafka, kafka-consumer-api
Перевірте, чи порожня черга Кафки - clojure, apache-кафка, clj-kafka
Зоокіпер: як користуватися споживачем високого рівня, щоб знайти перелік брокерів kafka - apache-zookeeper, apache-kafka
Кафка побічна обробка пошкоджень та повторна доставка - apache-kafka, kafka-consumer-api, spring-kafka
кафка споживач у сценарії оболонки - apache-kafka, kafka-consumer-api
Розподіл журналу Кафка серед споживачів - apache-kafka, message-queue
Kafka 0.10.1.0 зміна часу компенсації - apache-кафка, компенсація, споживач
Відображення розділу "Кафка" Кафка для споживачів / споживачів - apache-kafka, kafka-consumer-api
Кафка: помилка в SyncGroup, час закінчення запиту - apache-kafka, kafka-consumer-api
Kafka consumer api (без конфігурації zookeeper) - apache-kafka
Чи має кафка верхню межу того, скільки споживачів він може підтримувати? - apache-kafka, kafka-consumer-api, kafka-prod-api
Kafka Consumer не використовує повідомлення з усіх розділів - apache-kafka, kafka-consumer-api
Як сповістити виробника у кафці? - апаше-кафка
як запустити кафка сервера програмно - apache-kafka, spring-kafka
Кафка, як правильно споживати паралельну тему - apache-kafka, consumer, kafka-consumer-api
кафка розділу перебалансування (призначення) займає надто багато часу - apache-kafka, kafka-consumer-api, kafka-prod-api
Consumer Pause & Resume працює на рівні ConsumerGroup? - apache-kafka, kafka-consumer-api