/ / Ako (má) Kafka Spotrebiteľ sa vyrovnať s Poison Messages - apache-kafka, kafka-consumer-api

Ako by mal Kafka spotrebiteľ vyrovnať s jedovatými správami - apache-kafka, kafka-spotrebiteľ-api

Keď spotrebiteľ Kafka nedokáže deserializovať správu, je zodpovednosťou klientskej aplikácie zaoberať sa správou o jedoch?

alebo

Má Kafka "prírastok" správy posunutej a pokračuje v spotrebe platných správ?

Existuje "Best Practice" pre riešenie jedových správ na témy Kafka?

odpovede:

2 pre odpoveď č. 1

Keď Kafka nie je schopná deserializovať záznam, spotrebiteľ ho dostane org.apache.kafka.common.KafkaException, mali by ste sa dopustiť kompenzácie sami a spotrebovávať.

Súvisiace otázky

Ako vystaviť spotrebiteľskú službu pre kafku ako nepretržitého poslucháča - jar, cxf, jarná integrácia, apache-kafka, kafka-spotrebiteľ-api
Spark Streaming s Kafkou v Scale - scala, apache-spark, apache-kafka
Apache Kafka, uzol js a pracovný postup Point-to-Point - node.js, apache-kafka, kafka-consumer-api
Kafka - vytvorenie skupiny spotrebiteľov so špecifickým offsetom? - java, apache-zookeeper, apache-kafka, kafka-spotrebiteľ-api
Skontrolujte, či je fronta Kafka prázdna - clojure, apache-kafka, clj-kafka
Zookeeper: Ako používať spotrebiteľov na vysokej úrovni, aby ste našli zoznam maklérov kafky - apache-zookeeper, apache-kafka
Kafka zlyhanie spotrebiteľov zlyhanie a redelivery - apache-kafka, kafka-spotrebiteľ-api, spring-kafka
kafka spotrebiteľ v škrupine skript - apache-kafka, kafka-spotrebiteľ-api
Distribúcia denníka Kafka medzi spotrebiteľmi - apache-kafka, fronta správ
Kafka 0.10.1.0 zmena času ofsetu - apache-kafka, ofset, spotrebiteľ
Mapovanie rozdelenia Kafka medzi spotrebiteľské a spotrebiteľské skupiny Kafka - apache-kafka, kafka-consumer-api
Kafka: Chyba od SyncGroup, žiadosť vypršala - apache-kafka, kafka-consumer-api
Kafka spotrebiteľská api (bez konfigurácie zookeeper) - apache-kafka
Má kafka hornú hranicu, koľko spotrebiteľov môže podporiť? - apache-kafka, kafka-spotrebiteľ-api, kafka-producent-api
Spotrebiteľ Kafka spotrebováva správy zo všetkých oddielov - apache-kafka, kafka-consumer-api
Ako oznamovať výrobcovi v kafke? - apache-kafka
ako naštartovať kafka server programovo - apache-kafka, spring-kafka
Kafka ako konzumovať viac tém paralelne - apache-kafka, spotrebiteľ, kafka-spotrebiteľ-api
kafka oddelenie vyvažovania (zadanie) trvá príliš veľa času - apache-kafka, kafka-spotrebiteľ-api, kafka-producent-api
Spotrebiteľská pauza & Resume funguje na úrovni ConsumerGroup? - apache-kafka, kafka-spotrebiteľ-api