TopicConsumer
2021-11-15 23:24:22 5 举报Kafka消费者的设计
作者其他创作
大纲/内容
commonKafkaConsumerconsumeTopics(consumerRecord)
jdkConsumer
key:topic
getTopics()
consumersMap
@KafkaListener(topics = \
accept(value)
proxyXxxService
get(topic)
inject():xxxService
init()
Topic执行器
deserialize(value)
annotated()
@TopicConsumer(topic)consume(xxxMessage)
consumers
consume(xxxMessage)
SpringBeanFactory
topicConsumer
Kafka中间件
mapping()
keySet()
inject():topicExecutor
value:consumer
0 条评论
下一页
为你推荐
查看更多
抱歉，暂无相关内容