kafaka消費端工作流程

消費者的組件 KakfaConsumer:消費端,用於啓動消費者進程來消費消息。 ConsumerConfig:消費端配置管理,用於給消費端配置相關參數,比如指定 Kafka 集羣,設置自動提交和自動提交時間間隔等等參數,都由其來管理。 ConsumerConnector:消費者連接器,通過消費者連接器可以獲得 Kafka 消息流,然後通過消息流就能獲得消息從而使得客戶端開始消費消息。 消費者消費
相關文章
相關標籤/搜索