diff --git a/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala b/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala index 5bb7216ab8d..d8635367ac4 100644 --- a/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala +++ b/core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala @@ -209,14 +209,6 @@ class GroupMetadataManager(brokerId: Int, } } - // visible for testing - private[group] def isGroupOpenForProducer(producerId: Long, groupId: String) = openGroupsForProducer.get(producerId) match { - case Some(groups) => - groups.contains(groupId) - case None => - false - } - /** * Get the group associated with the given groupId or null if not found */