并行消费kafka存放本地文件

package com.tvm.writefile; /** * Created by zhangx on 2017/1/25. */ import com.alibaba.fastjson.JSONObject; import kafka.consumer.ConsumerConfig; import kafka.consumer.ConsumerIterator; import kaf
相关文章
相关标签/搜索