Package com.adaptris.kafka

Class MimeEncoderDeserializer

java.lang.Object

com.adaptris.kafka.AdaptrisMessageDeserializer

com.adaptris.kafka.MimeEncoderDeserializer

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.common.serialization.Deserializer<AdaptrisMessage>

public class MimeEncoderDeserializer
extends AdaptrisMessageDeserializer

Deserializer implementation for AdaptrisMessage objects that uses MimeEncoder.

Note the this deserializer should be used in conjunction with MimeEncoderSerializer.

Since:

3.8.0

Field Summary

Fields inherited from class com.adaptris.kafka.AdaptrisMessageDeserializer

factory, KAFKA_TOPIC_KEY

Constructor Summary

Constructors

Constructor	Description
MimeEncoderDeserializer()

Method Summary

Modifier and Type	Method	Description
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
AdaptrisMessage	deserialize(java.lang.String topic, byte[] data)

Methods inherited from class com.adaptris.kafka.AdaptrisMessageDeserializer

close

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

deserialize

Constructor Detail

MimeEncoderDeserializer

public MimeEncoderDeserializer()

Method Detail

configure

public void configure(java.util.Map<java.lang.String,?> configs,
                      boolean isKey)

Specified by:

configure in interface org.apache.kafka.common.serialization.Deserializer<AdaptrisMessage>

Overrides:

configure in class AdaptrisMessageDeserializer

deserialize

public AdaptrisMessage deserialize(java.lang.String topic,
                                   byte[] data)

Specified by:

deserialize in interface org.apache.kafka.common.serialization.Deserializer<AdaptrisMessage>

Overrides:

deserialize in class AdaptrisMessageDeserializer