THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Table of Contents |
---|
Status
Current state: Under DiscussionSuperseeded by KIP-699
Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]
...
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.
...
- Update the batching logic in KafkaAdmin.java directly instead of modifying the structure of requests and response.
- Change the builder.build()'s return type to a Collection;