originalMessage
originalMessage: { key: KafkaMessage["key"]; offset: KafkaMessage["offset"]; partition: number; timestamp: KafkaMessage["timestamp"]; value: KafkaMessage["value"] }
Type declaration
-
key: KafkaMessage["key"]
-
offset: KafkaMessage["offset"]
-
partition: number
-
timestamp: KafkaMessage["timestamp"]
-
value: KafkaMessage["value"]