org.apache.storm.kafka

Interface MessageMetadataScheme

All Superinterfaces:

Scheme, Serializable

All Known Implementing Classes:

StringMessageAndMetadataScheme

public interface MessageMetadataScheme
extends Scheme

Method Summary

Modifier and Type	Method and Description
List<Object>	deserializeMessageWithMetadata(ByteBuffer message, Partition partition, long offset)

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

deserialize, getOutputFields

Method Detail

deserializeMessageWithMetadata

List<Object> deserializeMessageWithMetadata(ByteBuffer message,
                                            Partition partition,
                                            long offset)