记一次kafka消费能力优化

以前的代码: 有多个source:多个kafka,一个ESphp 1.消费者数据接口java interface Source { List<String> poll(); } 2.implweb class KafkaSource implement Source { List<String> poll() { ConsumerRecords<String,String>
相关文章
相关标签/搜索