consumer.subscribe
时间: 2023-08-27 07:14:02 浏览: 46
consumer.subscribe方法是用于订阅消息的。通过该方法,Consumer可以指定要订阅的topic,以便接收该topic下的消息。在broker端,ConsumerManager会保存这个订阅信息,以便在传递消息给Consumer时进行过滤,并将消息发送到对应的Consumer的channel上。 consumer.subscribe方法实际上在broker端建立了Consumer、topic、tag的映射关系,以便在传递消息时进行过滤,确定是否发送给Consumer。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* [Kafka消费者订阅指定主题(subscribe)或分区(assign)详解](https://blog.csdn.net/Urbanears/article/details/126126496)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"]
- *2* *3* [RocketMQ Consumer如何订阅消息的?](https://blog.csdn.net/GAMEloft9/article/details/103886738)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]