GitHub-Proxy/signoz
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz synced 2025-08-16 19:15:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #5769 from shivanshuraj1333/tmp

Browse Source 
small patch to fix consumer_group check
This commit is contained in:
Shivanshu Raj Shrivastava 2024-08-26 17:47:19 +05:30 committed by GitHub
commit 2ca10bb87c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/query-service/app/integrations/messagingQueues/kafka/translator.go
View File

@ -48,15 +48,14 @@ func buildClickHouseQuery(messagingQueue *MessagingQueue, queueType string, quer
return nil, fmt.Errorf("invalid type for Partition")
}
consumerGroup, ok := messagingQueue.Variables["consumer_group"]
if !ok {
return nil, fmt.Errorf("invalid type for consumer group")
}
var query string
if queryContext == "producer" {
query = generateProducerSQL(start, end, topic, partition, queueType)
} else if queryContext == "consumer" {
consumerGroup, ok := messagingQueue.Variables["consumer_group"]
if !ok {
return nil, fmt.Errorf("invalid type for consumer group")
}
query = generateConsumerSQL(start, end, topic, partition, consumerGroup, queueType)
}