nizhikov commented on PR #16106:
URL: https://github.com/apache/kafka/pull/16106#issuecomment-2154948558
Hello
@cmccabe
@AndrewJSchofield
@showuon
I struggle with the `DescribeQuorumRequestTest` - the test send request of
all existing versions and check results.
It's not clear on how I can handle specific request version when creating
response:
`DescribeQuorumResponse#singletonResponse` have no access to request version
but `DescribeQuorumResponseData#write` check that nodes are not set for
previous versions:
```
@Override
public void write(Writable _writable, ObjectSerializationCache _cache,
short _version) {
...
if (_version >= 2) {
_writable.writeUnsignedVarint(nodes.size() + 1);
for (Node nodesElement : nodes) {
nodesElement.write(_writable, _cache, _version);
}
} else {
if (!this.nodes.isEmpty()) {
throw new UnsupportedVersionException("Attempted to write a
non-default nodes at version " + _version); // Test fails here.
}
}
```
Can you, please, show me an example - how previous request versions must be
handled?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
