Class CommitMetadata


  • public class CommitMetadata
    extends Object
    Object representing metadata committed to Kafka.
    • 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()