public class CommitMetadata extends Object
Object representing metadata committed to Kafka.
| Constructor and Description |
|---|
CommitMetadata(String topologyId,
int taskId,
String threadName)
Kafka metadata.
|
| Modifier and Type | Method and Description |
|---|---|
int |
getTaskId() |
String |
getThreadName() |
String |
getTopologyId() |
String |
toString() |
Copyright © 2021 The Apache Software Foundation. All rights reserved.