kafaka消费端工作流程

消费者的组件 KakfaConsumer:消费端,用于启动消费者进程来消费消息。 ConsumerConfig:消费端配置管理,用于给消费端配置相关参数,比如指定 Kafka 集群,设置自动提交和自动提交时间间隔等等参数,都由其来管理。 ConsumerConnector:消费者连接器,通过消费者连接器可以获得 Kafka 消息流,然后通过消息流就能获得消息从而使得客户端开始消费消息。 消费者消费
相关文章
相关标签/搜索