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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getTaskId()
String
getThreadName()
String
getTopologyId()
String
toString()
-