Package 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	Description
CommitMetadata(String topologyId, int taskId, String threadName)	Kafka metadata.

Method Summary

Modifier and Type	Method	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 Details

CommitMetadata

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

Kafka metadata.

Method Details

getTopologyId

public String getTopologyId()

getTaskId

public int getTaskId()

getThreadName

public String getThreadName()

toString

public String toString()

Overrides:

toString in class Object