diff --git a/pkg/connector/service.go b/pkg/connector/service.go index 7b8e5cfd2..a0714ad7f 100644 --- a/pkg/connector/service.go +++ b/pkg/connector/service.go @@ -197,6 +197,9 @@ func (s *Service) Update(ctx context.Context, id string, plugin string, data Con return nil, err } + if conn.Plugin != plugin { + s.logger.Warn(ctx).Msgf("connector pluging changing from %v to %v, this may lead to unexpected behavior and configuration issues.") + } conn.Plugin = plugin conn.Config = data conn.UpdatedAt = time.Now().UTC()