Skip to content

Commit 45e0818

Browse files
authored
temp: extra logging for topicInfo (#33)
1 parent 47e5c04 commit 45e0818

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

pkg/apply/apply.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -266,6 +266,7 @@ func (t *TopicApplier) Apply(ctx context.Context) (NewOrUpdatedChanges, error) {
266266
log.Info("Checking if topic already exists...")
267267

268268
topicInfo, err := t.adminClient.GetTopic(ctx, t.topicName, true)
269+
log.Infof("topic info for %s: %+v", t.topicName, topicInfo)
269270
if err != nil {
270271
// if the topic doesn't exist, create it
271272
if err == admin.ErrTopicDoesNotExist {

0 commit comments

Comments
 (0)