org.springframework.integration.x.kafka

Class StringDecoder

java.lang.Object

org.springframework.integration.x.kafka.StringDecoder

All Implemented Interfaces:

kafka.serializer.Decoder<java.lang.String>

public class StringDecoder
extends java.lang.Object
implements kafka.serializer.Decoder<java.lang.String>

String Decoder for Kafka message key/value decoding. The Default decoder returns the same byte array it takes in.

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor and Description
StringDecoder()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	fromBytes(byte[] bytes)
void	setEncoding(java.lang.String encoding)

Methods inherited from class java.lang.Object

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

Constructor Detail

StringDecoder

public StringDecoder()

Method Detail

setEncoding

public void setEncoding(java.lang.String encoding)

fromBytes

public java.lang.String fromBytes(byte[] bytes)

Specified by:

fromBytes in interface kafka.serializer.Decoder<java.lang.String>