slbotbm commented on code in PR #3841:
URL: https://github.com/apache/iggy/pull/3841#discussion_r3740610881
##########
foreign/java/java-sdk/src/main/java/org/apache/iggy/serde/BytesDeserializer.java:
##########
@@ -177,13 +180,45 @@ public static ConsumerGroup readConsumerGroup(ByteBuf
response) {
return new ConsumerGroup(groupId, name, partitionsCount, membersCount);
}
+ public static ConsumerGroupAssignment readConsumerGroupAssignment(ByteBuf
response) {
+ // The generation is a monotonic rebalance counter compared only for
+ // equality, so reading the u64 as a signed long is safe.
+ var generation = response.readLongLE();
+ var partitionsCount = response.readUnsignedIntLE();
+ List<Long> partitions = new ArrayList<>(toInt(partitionsCount));
+ for (long i = 0; i < partitionsCount; i++) {
+ partitions.add(response.readUnsignedIntLE());
+ }
+ return new ConsumerGroupAssignment(generation, partitions);
Review Comment:
Resolved
--
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]
