public void shutdown() {
for (BlockingQueue<FetchedDataChunk> queue : this.queues) {
queue.add(ZookeeperConsumerConnector.shutdownCommand());
}
}
MockKafkaStream.java 文件源码
java
阅读 24
收藏 0
点赞 0
评论 0
项目：incubator-gobblin
作者:
评论列表
文章目录
