mirror of https://github.com/apache/kafka.git
MINOR: remove redudant return statement (#9535)
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
parent
ee1aa07036
commit
d7aaa7007c
|
|
@ -361,7 +361,6 @@ class GroupMetadataManager(brokerId: Int,
|
|||
// compute the final error codes for the commit response
|
||||
val commitStatus = offsetMetadata.map { case (k, _) => k -> Errors.OFFSET_METADATA_TOO_LARGE }
|
||||
responseCallback(commitStatus)
|
||||
None
|
||||
} else {
|
||||
getMagic(partitionFor(group.groupId)) match {
|
||||
case Some(magicValue) =>
|
||||
|
|
@ -477,7 +476,6 @@ class GroupMetadataManager(brokerId: Int,
|
|||
(topicPartition, Errors.NOT_COORDINATOR)
|
||||
}
|
||||
responseCallback(commitStatus)
|
||||
None
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue