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) } }