記一次kafka消費能力優化

以前的代碼: 有多個source:多個kafka,一個ESphp 1.消費者數據接口java interface Source { List<String> poll(); } 2.implweb class KafkaSource implement Source { List<String> poll() { ConsumerRecords<String,String>
相關文章
相關標籤/搜索