From df25ed3c5be7e1984f8a9316cbaa3deb824276fb Mon Sep 17 00:00:00 2001
From: Chris Lu <chris.lu@gmail.com>
Date: Sun, 19 Apr 2020 23:37:40 -0700
Subject: [PATCH] logs

---
 weed/messaging/broker/topic_lock.go | 2 ++
 1 file changed, 2 insertions(+)

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,