打扰了,问一下 type SimpleProcessFactory struct { //用户自定义信息,会传递到ProcessFunc和ShutdownFunc中的ChannelContext参数中。 CustomValue interface{}
//Worker记录checkpoint的间隔,CpInterval<=0时会使用DefaultCheckpointInterval。 CpInterval time.Duration
//worker数据处理的同步调用callback,ProcessFunc返回error时worker会用本批数据退避重试ProcessFunc。 ProcessFunc func(channelCtx *ChannelContext, records []*Record) error //worker退出时的同步调用callback。 ShutdownFunc func(channelCtx *ChannelContext)
//日志配置,Logger为nil时会使用DefaultLogConfig初始化logger。 Logger *zap.Logger } worker数据处理的同步调用callback,ProcessFunc返回error时worker会用本批数据退避重试ProcessFunc 已经返回了error ,结果没有使用本批次数据重试,什么问题?
您好!
根据您提供的上下文,我无法准确判断结果没有使用本批次数据重试的原因。
如果您想了解有关结果没有使用本批次数据重试的更多信息,请提供更多上下文或详细说明。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。