Skip to content

Commit

Permalink
split line
Browse files Browse the repository at this point in the history
  • Loading branch information
PGarule authored and PGarule committed Jul 18, 2022
1 parent 3d21b01 commit 5147054
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion pulsar/consumer_partition.go
Original file line number Diff line number Diff line change
Expand Up @@ -552,7 +552,8 @@ func (pc *partitionConsumer) internalSeekByTime(seek *seekByTimeRequest) {
seek.err = err
return
}
pc.log.Debugf("Successfully reset subscriptio to timestamp : %v", uint64(seek.publishTime.UnixNano()/int64(time.Millisecond)))
pc.log.Debugf("Successfully reset subscriptio to timestamp : %v",
uint64(seek.publishTime.UnixNano()/int64(time.Millisecond)))
pc.clearMessageChannels()
}

Expand Down

0 comments on commit 5147054

Please sign in to comment.