From 9476d6ef9ad6f6a502740b1b9ad93220892fd804 Mon Sep 17 00:00:00 2001 From: Jim Plush Date: Thu, 28 Sep 2017 14:03:01 -0700 Subject: [PATCH] The addBrokerOffset function was attempting to handle expanding partition counts in the topicList however, changes weren't reflected on the next update. So if you added more partitions to a topic they wouldn't show up. refrences https://github.com/linkedin/Burrow/issues/250 (#251) --- offsets_store.go | 1 + 1 file changed, 1 insertion(+) diff --git a/offsets_store.go b/offsets_store.go index 9f7cb5b7..a37d27e0 100644 --- a/offsets_store.go +++ b/offsets_store.go @@ -185,6 +185,7 @@ func (storage *OffsetStorage) addBrokerOffset(offset *protocol.PartitionOffset) partitionEntry.Timestamp = offset.Timestamp } + clusterMap.broker[offset.Topic] = topicList clusterMap.brokerLock.Unlock() }