From dd30168b1c27d7d2f4e6864004f2ed3b8c104844 Mon Sep 17 00:00:00 2001 From: Jacob Brinlee <66123601+jrbrinlee1@users.noreply.github.com> Date: Thu, 3 Nov 2022 09:20:49 -0500 Subject: [PATCH] updating topic/partition/offset order (#2250) * updating order of topic/partition/offset in log message --- 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 597899800..a7728e473 100644 --- a/idk/kafka/source.go +++ b/idk/kafka/source.go @@ -240,7 +240,7 @@ func (r *Record) Commit(ctx context.Context) error { if r.src.Verbose { for _, o := range committedOffsets { - r.src.Log.Debugf("p: %v t: %v o: %v", o.Partition, *o.Topic, o.Offset) + r.src.Log.Debugf("t: %v p: %v o: %v", *o.Topic, o.Partition, o.Offset) } }