Kafka stores and transports byte arrays in its queue. The (de)serializers are responsible for translating between the byte array provided by Kafka and POJOs.
|config||the configuration properties (|
|isKey||custom (de)serializers can be used for keys and/or values. This parameter tells you which of the two this instance will deal with.|
|topic||the topic of the current message. This lets you define custom logic based on the source/destination topic.|
|bytes||The raw message to deserialize|
|obj||The message to serialize. Its actual class depends on your serializer.|
Before version 0.9.0.0 the Kafka Java API used
Decoders. They have been replaced by
Deserializer in the new API.