Skip to content

Commit

Permalink
Merge pull request #427 from sciclon2/Fix-protocolType-consumer
Browse files Browse the repository at this point in the history
Fix Error Handling in Member Assignment to Ensure Seamless Processing
  • Loading branch information
danielqsj authored Aug 20, 2024
2 parents 3b37dc8 + e4cca9c commit b41c0c4
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion kafka_exporter.go
Original file line number Diff line number Diff line change
Expand Up @@ -590,7 +590,7 @@ func (e *Exporter) collect(ch chan<- prometheus.Metric) {
assignment, err := member.GetMemberAssignment()
if err != nil {
klog.Errorf("Cannot get GetMemberAssignment of group member %v : %v", member, err)
return
continue
}
for topic, partions := range assignment.Topics {
for _, partition := range partions {
Expand Down

0 comments on commit b41c0c4

Please sign in to comment.