Skip to content

Latest commit

 

History

History
23 lines (16 loc) · 759 Bytes

kafka-streams-RecordDeserializer.adoc

File metadata and controls

23 lines (16 loc) · 759 Bytes

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