Type Members

1.  abstract class ConsumerRecordDeserializationSchemaFactory[K, V] extends KafkaDeserializationSchemaFactory[ConsumerRecord[K, V]] with Serializable

   Produces deserialization schema that describes how to turn the Kafka raw org.apache.kafka.clients.consumer.ConsumerRecord (with raw key-value of type Array[Byte]) into deserialized ConsumerRecord[K, V] (with proper key-value types).

   Produces deserialization schema that describes how to turn the Kafka raw org.apache.kafka.clients.consumer.ConsumerRecord (with raw key-value of type Array[Byte]) into deserialized ConsumerRecord[K, V] (with proper key-value types). It allows the source to provide event value AND event metadata to the stream.

   K

   - type of key of deserialized ConsumerRecord

   V

   - type of value of deserialized ConsumerRecord

2.  class ConsumerRecordToJsonFormatter[K, V] extends RecordFormatter
3.  class ConsumerRecordToJsonFormatterFactory[K, V] extends RecordFormatterFactory

   RecordFormatter used to encode and decode whole raw kafka event (ConsumerRecord) in json format.

   RecordFormatter used to encode and decode whole raw kafka event (ConsumerRecord) in json format.

   K

   - event key type with provided Encoder/Decoder

   V

   - event value type with provided Encoder/Decoder

4.  case class SerializableConsumerRecord[K, V](key: Option[K], value: V, topic: Option[String], partition: Option[Int], offset: Option[Long], timestamp: Option[Long], timestampType: Option[String], headers: Option[Map[String, Option[String]]], leaderEpoch: Option[Int]) extends Product with Serializable

   Wrapper for ConsumerRecord fields used for test data serialization, eg.

   Wrapper for ConsumerRecord fields used for test data serialization, eg. json serialization. All fields apart from value are optional.