package consumerrecord
- Alphabetic
- Public
- All
Type Members
-
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
- class ConsumerRecordToJsonFormatter[K, V] extends RecordFormatter
-
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
-
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.
Value Members
- object ConsumerRecordDeserializationSchemaFactory extends Serializable
- object SerializableConsumerRecord extends Serializable