package consumerrecord
Type Members
-
class
FixedValueDeserializationSchemaFactory[V] extends ConsumerRecordDeserializationSchemaFactory[String, V]
Wrapper for value-only Flink's DeserializationSchema.
Wrapper for value-only Flink's DeserializationSchema. For kafka event key data it uses simple "Array[Byte] to String" deserialization. Used with simple, value-only, sources where event key is empty or ignored. It is similar to ConsumerRecordDeserializationSchemaFactory.fixedValueDeserialization but doesn't lost Flink's TypeInformation
- V
- type of value of deserialized ConsumerRecord