diff --git a/pkg/apply/apply.go b/pkg/apply/apply.go index fa04a708..ff6104fc 100644 --- a/pkg/apply/apply.go +++ b/pkg/apply/apply.go @@ -266,7 +266,6 @@ func (t *TopicApplier) Apply(ctx context.Context) (NewOrUpdatedChanges, error) { log.Info("Checking if topic already exists...") topicInfo, err := t.adminClient.GetTopic(ctx, t.topicName, true) - log.Infof("topic info for %s: %+v", t.topicName, topicInfo) if err != nil { // if the topic doesn't exist, create it if err == admin.ErrTopicDoesNotExist {