/**
* @return Returns the defined partitions as a Set.
*/
@Transient
public Set<Integer> getPartitionsAsSet() {
final Set<Integer> partitionsSet = new HashSet<>();
// Avoid NPE.
if (getPartitions() == null) {
return partitionsSet;
}
final String[] partitions = getPartitions().split(",");
for (final String partitionStr: partitions) {
try {
partitionsSet.add(Integer.parseInt(partitionStr));
} catch (NumberFormatException e) {
// Ignore?
}
}
return partitionsSet;
}
View.java 文件源码
java
阅读 46
收藏 0
点赞 0
评论 0
项目:kafka-webview
作者:
评论列表
文章目录