Skip to content

Commit

Permalink
Remove unused method
Browse files Browse the repository at this point in the history
  • Loading branch information
sopel39 committed Sep 27, 2019
1 parent 10cf82d commit 8d82a10
Showing 1 changed file with 0 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -83,11 +83,6 @@ private List<Partition<T>> createPartitions(
return partitions.build();
}

public int getConsumersCount()
{
return consumersCount;
}

public Iterator<Partition<T>> beginConsumption()
{
Queue<Partition<T>> partitions = new ArrayDeque<>(requireNonNull(this.partitions, "partitions is already null"));
Expand Down

0 comments on commit 8d82a10

Please sign in to comment.