From 158239ea11f23035c25d65f676a1e519962dd09d Mon Sep 17 00:00:00 2001 From: Guillaume Bailey Date: Mon, 17 Apr 2017 12:21:38 -0700 Subject: [PATCH] Add special UUID to kafka CGE detection heuristic --- common/metadata.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/common/metadata.go b/common/metadata.go index 11a29f0e..8b87fb85 100644 --- a/common/metadata.go +++ b/common/metadata.go @@ -39,5 +39,6 @@ func IsDLQDestinationPath(path string) bool { // IsKafkaConsumerGroupExtent determines if a consumer group extent is a Kafka consumption assignment func IsKafkaConsumerGroupExtent(e *shared.ConsumerGroupExtent) bool { - return len(e.GetStoreUUIDs()) <= 1 // TODO: Replace this heuristic when CGE metadata has been updated + l := len(e.GetStoreUUIDs()) // TODO: Replace this heuristic when CGE metadata has been updated + return l == 0 || (l == 1 && e.GetStoreUUIDs()[0] == `00000000-0000-0000-0000-000000000000`) }