property KafkaOptions.onMalformedMessage

Callback for handling malformed messages that cannot be parsed.

Called when a message cannot be deserialized. If not provided, malformed messages are silently skipped.

Type

(
topic: string,
partition: number,
offset: string,
raw: string,
) => void

Usage

import { type KafkaOptions } from ".";