the.bay.news

One bad Kafka record shouldn't crash a Flink Stateful Functions job

DEV Community
One bad Kafka record shouldn't crash a Flink Stateful Functions job
A single null-key record crashed a whole Stateful Functions job. KZM-3.5 ships invalidRecordHandling - skip by default, strict fail per topic, full per-record diagnostics.

0 comments

Sign in to join the discussion — your thebay.events account works here.

No comments yet.