Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
hughsimpson committed May 24, 2024
1 parent 3d87c0a commit 7552be3
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -67,8 +67,8 @@ private[kafka] object RecordProcessor {
case meta: ConsumerGroupMetadata => Some(meta.groupId())
}
else None
case value: String => Option(value)
case value: String => Option(value)
case coord: ConsumerCoordinator => Some(coord.groupMetadata().groupId())
case _ => None
case _ => None
}
}

0 comments on commit 7552be3

Please sign in to comment.