diff options
Diffstat (limited to 'weed/messaging/broker/topic_manager.go')
| -rw-r--r-- | weed/messaging/broker/topic_manager.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/messaging/broker/topic_manager.go b/weed/messaging/broker/topic_manager.go index b563fffa1..93815f8f4 100644 --- a/weed/messaging/broker/topic_manager.go +++ b/weed/messaging/broker/topic_manager.go @@ -56,6 +56,7 @@ func (tm *TopicManager) buildLogBuffer(tl *TopicControl, tp TopicPartition, topi // fmt.Printf("flushing with topic config %+v\n", topicConfig) + startTime, stopTime = startTime.UTC(), stopTime.UTC() targetFile := fmt.Sprintf( "%s/%s/%s/%04d-%02d-%02d/%02d-%02d.part%02d", filer2.TopicsDir, tp.Namespace, tp.Topic, |