FB-1696 - fixed debug message to show topic's name instead of topic's address

This commit is contained in:
Hoang Pham 2022-10-04 12:34:09 -05:00 • committed by Fletcher Haynes
parent 9b3e236ce5
commit 631d7e84dc

View file

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