Package io.confluent.kafka.serializers.wrapper

Class CompositeDeserializer

java.lang.Object

io.confluent.kafka.serializers.wrapper.CompositeDeserializer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.serialization.Deserializer<Object>

public class CompositeDeserializer
extends Object
implements org.apache.kafka.common.serialization.Deserializer<Object>

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
CompositeDeserializer()	Constructor used by Kafka consumer.

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	configure(CompositeDeserializerConfig config, boolean isKey)
void	configure(Map<String,?> configs, boolean isKey)
Object	deserialize(String topic, byte[] bytes)
Object	deserialize(String topic, org.apache.kafka.common.header.Headers headers, byte[] bytes)
org.apache.kafka.common.serialization.Deserializer<?>	getConfluentDeserializer()
org.apache.kafka.common.serialization.Deserializer<?>	getOldDeserializer()

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

Field Details

log

protected org.slf4j.Logger log

Constructor Details

CompositeDeserializer

public CompositeDeserializer()

Constructor used by Kafka consumer.

Method Details

configure

public void configure(Map<String,?> configs,
 boolean isKey)

Specified by:

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

configure

protected void configure(CompositeDeserializerConfig config,
 boolean isKey)

getOldDeserializer

public org.apache.kafka.common.serialization.Deserializer<?> getOldDeserializer()

getConfluentDeserializer

public org.apache.kafka.common.serialization.Deserializer<?> getConfluentDeserializer()

deserialize

public Object deserialize(String topic,
 byte[] bytes)

Specified by:

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

deserialize

public Object deserialize(String topic,
 org.apache.kafka.common.header.Headers headers,
 byte[] bytes)

Specified by:

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

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.apache.kafka.common.serialization.Deserializer<Object>