Package org.apache.kafka.connect.storage
package org.apache.kafka.connect.storage
Provides pluggable interfaces and some implementations for (de)serializing data to and from Kafka
-
ClassDescriptionThe Converter interface provides support for translating between Kafka Connect's runtime data format and byte[].Abstract class that defines the configuration options for
Converter
andHeaderConverter
instances.The type ofConverter
andHeaderConverter
.The HeaderConverter interface provides support for translating between Kafka Connect's runtime data format and byte[].OffsetStorageReader provides access to the offset storage used by sources.AHeaderConverter
that serializes header values as strings and that deserializes header values to the most appropriate numeric, boolean, array, or map representation.Converter
andHeaderConverter
implementation that only supports serializing to strings.Configuration options forStringConverter
instances.