RecordDeserializer

RecordDeserializer is the metadata of a SourceNode that knows how to deserialize a raw ConsumerRecord.

RecordDeserializer takes the following when created:

  • SourceNode

  • DeserializationExceptionHandler

  • LogContext

Deserializing Kafka ConsumerRecord (in ProcessorContext) — deserialize Method

ConsumerRecord<Object, Object> deserialize(
  final ProcessorContext processorContext,
  final ConsumerRecord<byte[], byte[]> rawRecord)

deserialize…​FIXME

Note
 deserialize is used when…​FIXME

results matching ""

    No results matching ""