diff --git a/pkg/apply/apply.go b/pkg/apply/apply.go index ff6104fc..fa04a708 100644 --- a/pkg/apply/apply.go +++ b/pkg/apply/apply.go @@ -266,6 +266,7 @@ 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 {