org.springframework.integration.kafka.serializer.common
Class StringDecoder

java.lang.Object
  extended by org.springframework.integration.kafka.serializer.common.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.


Constructor Summary
StringDecoder()
           
StringDecoder(java.lang.String encoding)
           
 
Method Summary
 java.lang.String fromBytes(byte[] bytes)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StringDecoder

public StringDecoder()

StringDecoder

public StringDecoder(java.lang.String encoding)
Method Detail

fromBytes

public java.lang.String fromBytes(byte[] bytes)
Specified by:
fromBytes in interface kafka.serializer.Decoder<java.lang.String>