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 intgetTaskId()StringgetThreadName()StringgetTopologyId()StringtoString()
-