THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
public List<FindCoordinatorRequest> buildToList(short version) { if (version < minVersion) throw new UnsupportedVersionException("Cannot create a v" + version + " FindCoordinator request " + "because we require features supported only in " + minVersion + " or later."); return groupIds.entrySet() .stream() .map(x-> new FindCoordinatorRequest(x.value(), x.key(), version)) .collect(Collectors.toList()); } |
Then in NetworkClient.java/doSend(), use instanceof to check if batching has been used.
...