From b251090bf7e7dede7850e4abc8e1e87e3d67c50a Mon Sep 17 00:00:00 2001 From: chrislu Date: Tue, 18 Nov 2025 21:53:38 -0800 Subject: [PATCH] Activity Tracking for Kafka Publishers --- weed/mq/topic/local_partition_offset.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/weed/mq/topic/local_partition_offset.go b/weed/mq/topic/local_partition_offset.go index ddbc132db..9c8a2dac4 100644 --- a/weed/mq/topic/local_partition_offset.go +++ b/weed/mq/topic/local_partition_offset.go @@ -28,6 +28,9 @@ func (p *LocalPartition) PublishWithOffset(message *mq_pb.DataMessage, assignOff return 0, fmt.Errorf("failed to add message to buffer: %w", err) } + // Track publish activity for idle cleanup (consistent with Publish method) + p.UpdateActivity() + // Send to follower if needed (same logic as original Publish) if p.publishFolloweMeStream != nil { if followErr := p.publishFolloweMeStream.Send(&mq_pb.PublishFollowMeRequest{