public static class KafkaInboundChannelModel.TopicPartition extends Object
| Modifier and Type | Field and Description |
|---|---|
protected Collection<String> |
partitions |
protected String |
topic |
| Constructor and Description |
|---|
TopicPartition() |
| Modifier and Type | Method and Description |
|---|---|
Collection<String> |
getPartitions() |
String |
getTopic() |
void |
setPartitions(Collection<String> partitions) |
void |
setTopic(String topic) |
protected String topic
protected Collection<String> partitions
public String getTopic()
public void setTopic(String topic)
public Collection<String> getPartitions()
public void setPartitions(Collection<String> partitions)
Copyright © 2022 Flowable. All rights reserved.