diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-19 23:37:40 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-19 23:37:50 -0700 |
| commit | df25ed3c5be7e1984f8a9316cbaa3deb824276fb (patch) | |
| tree | a2fe1b3699e18a28403ad124b8aad61da937eab9 | |
| parent | ce3cb25cfbf30a06348386210f72cc51c3fbd13a (diff) | |
| download | seaweedfs-df25ed3c5be7e1984f8a9316cbaa3deb824276fb.tar.xz seaweedfs-df25ed3c5be7e1984f8a9316cbaa3deb824276fb.zip | |
logs
| -rw-r--r-- | weed/messaging/broker/topic_lock.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/messaging/broker/topic_lock.go b/weed/messaging/broker/topic_lock.go index 74861a147..c98bb3159 100644 --- a/weed/messaging/broker/topic_lock.go +++ b/weed/messaging/broker/topic_lock.go @@ -45,6 +45,8 @@ func (locks *TopicLocks) buildLogBuffer(tl *TopicLock, tp TopicPartition, topicC return } + // fmt.Printf("flushing with topic config %+v\n", topicConfig) + targetFile := fmt.Sprintf( "%s/%s/%s/%04d-%02d-%02d/%02d-%02d.part%02d", filer2.TopicsDir, tp.Namespace, tp.Topic, |