AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
SAT数据流梳理Callback
2021-05-17 10:52:21
7
举报
分享方式
免费使用
SAT数据流梳理Callback
软件开发
模版推荐
作者其他创作
大纲/内容
channelEntry.getChannelData()
回传工具类
判断状态
获取kafka消费者中任务
channel.doCallback(）
构造channel
ConfigContainer.current().getChannelFromProperties（）
CallbackUtils
将kafka消息、channel信息及CallBackResult存入Redis
获取kafka任务中的channelProperties
process（）
判断是否白名单
return callbackResult
ChannelCallbackProcessor
callbackResult中记录kafka偏移量及分区
ChannelToolSaveRedisUtils.saveMonitorCallback(）
尝试再次执行
kafka
将处理后的kafka偏移量等信息提交
callbackResult.setTopic（）callbackResult.setPartition(）callbackResult.setOffset(）
回传处理类
收藏
立即使用
SAT数据流梳理Callback
呜啦啦
职业：暂无
去主页
Collect
Get Started
【系统分析】数据流程图DFD（数据流图）
Collect
Get Started
数据流图
Collect
Get Started
consumer数据流
Collect
Get Started
callback
评论
0
条评论
下一页
Document
