並行消費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
相關文章
相關標籤/搜索