Add special UUID to kafka CGE detection heuristic

uber-archive · Apr 17, 2017 · 158239e · 158239e
1 parent eaa3a91
commit 158239e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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`)
 }