From bf00d028c73a2f27c39d9146c86b55434f5aa6f6 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 (cherry picked from commit dd30168b1c27d7d2f4e6864004f2ed3b8c104844) --- 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 6d1e4636b..769309896 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 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) } }