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(）
回传处理类
收藏
0 条评论
下一页
