public class TaskMetadata extends Object
KafkaStreams
application.Constructor and Description |
---|
TaskMetadata(String taskId,
Set<TopicPartition> topicPartitions) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
String |
taskId() |
Set<TopicPartition> |
topicPartitions() |
String |
toString() |
public TaskMetadata(String taskId, Set<TopicPartition> topicPartitions)
public String taskId()
public Set<TopicPartition> topicPartitions()