A payload for eachBatch where each message has been decoded with kafkajs SchemaRegistry
The decodeed type of the the kafka message value
Generated using TypeDoc
A payload for eachBatch where each message has been decoded with kafkajs SchemaRegistry