kakfa-adapter业务流程
2024-02-06 09:53:45 1 举报
Kafka-adapter业务流程主要包括以下几个步骤:首先,生产者将数据发送到Kafka集群中;然后,消费者从Kafka集群中读取数据;接着,数据处理模块对读取的数据进行处理;最后,处理后的数据被存储或输出。在这个过程中,Kafka-adapter起到了连接生产者、消费者和数据处理模块的作用,实现了数据的高效传输和处理。同时,Kafka-adapter还提供了一些高级功能,如消息过滤、消息排序等,进一步提高了数据处理的效率和准确性。
作者其他创作
大纲/内容
kafka消费线程池类
业务服务
3.从队列拉取task的消息
2.循环将消息添加到分区队列,全部提交完线程阻塞
EP消费消息同步sim卡到EP的es中
6.业务异常,异步将消息发送到死信主题
EP-kafka
7.业务处理完成计数器加一
分区消费者类
监听主线程
EP服务
消费者类
1.调用init()初始化队列,线程池,计数器将分区消费者实例分别提交到线程池中执行
8.等待计数器和消息拉取数一样,所有任务完成提交位移
0 条评论
下一页