org.apache.storm.kafka

Interface MessageMetadataScheme

All Superinterfaces:

Scheme, java.io.Serializable

All Known Implementing Classes:

StringMessageAndMetadataScheme

public interface MessageMetadataScheme
extends Scheme

Method Summary

Modifier and Type	Method and Description
java.util.List<java.lang.Object>	deserializeMessageWithMetadata(byte[] message, Partition partition, long offset)

Methods inherited from interface org.apache.storm.spout.Scheme

deserialize, getOutputFields

Method Detail

deserializeMessageWithMetadata

java.util.List<java.lang.Object> deserializeMessageWithMetadata(byte[] message,
                                                                Partition partition,
                                                                long offset)