org.apache.storm.kafka.spout.internal

Class CommitMetadata

java.lang.Object

org.apache.storm.kafka.spout.internal.CommitMetadata

public class CommitMetadata
extends Object

Object representing metadata committed to Kafka.

Constructor Summary

Constructors

Constructor and Description
CommitMetadata(String topologyId, int taskId, String threadName) Kafka metadata.

Method Summary

Modifier and Type	Method and Description
int	getTaskId()
String	getThreadName()
String	getTopologyId()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

CommitMetadata

public CommitMetadata(String topologyId,
                      int taskId,
                      String threadName)

Kafka metadata.

Method Detail

getTopologyId

public String getTopologyId()

getTaskId

public int getTaskId()

getThreadName

public String getThreadName()

toString

public String toString()

Overrides:

toString in class Object