diff --git a/backend/pkg/connector/guide/mirror_source.go b/backend/pkg/connector/guide/mirror_source.go index 6f398e634..5df0b5b67 100644 --- a/backend/pkg/connector/guide/mirror_source.go +++ b/backend/pkg/connector/guide/mirror_source.go @@ -57,6 +57,7 @@ func NewMirrorSourceGuide(opts ...Option) Guide { "producer.override.compression.type", "producer.override.max.request.size", "consumer.auto.offset.reset", + "offset.lag.max", }, }, },