diff options
Diffstat (limited to 'weed/messaging/broker/topic_lock.go')
| -rw-r--r-- | weed/messaging/broker/topic_lock.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/messaging/broker/topic_lock.go b/weed/messaging/broker/topic_lock.go index 652ff0545..74861a147 100644 --- a/weed/messaging/broker/topic_lock.go +++ b/weed/messaging/broker/topic_lock.go @@ -41,6 +41,10 @@ func (locks *TopicLocks) buildLogBuffer(tl *TopicLock, tp TopicPartition, topicC flushFn := func(startTime, stopTime time.Time, buf []byte) { + if topicConfig.IsTransient { + return + } + targetFile := fmt.Sprintf( "%s/%s/%s/%04d-%02d-%02d/%02d-%02d.part%02d", filer2.TopicsDir, tp.Namespace, tp.Topic, |