From 631d7e84dc72564f44c998fd0eb66c91130e1527 Mon Sep 17 00:00:00 2001 From: Hoang Pham Date: Tue, 4 Oct 2022 12:34:09 -0500 Subject: [PATCH] FB-1696 - fixed debug message to show topic's name instead of topic's address --- idk/kafka/source.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/idk/kafka/source.go b/idk/kafka/source.go index 52972bb10..6d1e4636b 100644 --- a/idk/kafka/source.go +++ b/idk/kafka/source.go @@ -239,7 +239,7 @@ func (r *Record) Commit(ctx context.Context) error { if r.src.Verbose { for _, o := range committedOffsets { - r.src.Log.Debugf("p: %v o: %v t: %v", o.Partition, o.Offset, o.Topic) + r.src.Log.Debugf("p: %v t: %v o: %v", o.Partition, *o.Topic, o.Offset) } }