AndrewJSchofield commented on code in PR #18455:
URL: https://github.com/apache/kafka/pull/18455#discussion_r1909976659
##########
coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRecordSerde.java:
##########
@@ -43,7 +43,7 @@ public abstract class CoordinatorRecordSerde implements
Serializer<CoordinatorRe
@Override
public byte[] serializeKey(CoordinatorRecord record) {
// Record does not accept a null key.
- return MessageUtil.toVersionPrefixedBytes(
+ return MessageUtil.toCoordinatorTypePrefixedBytes(
Review Comment:
Makes sense. Thanks for the explanation and matches why I thought you'd only
used `toCoordinatorTypePrefixedBytes` in the case of keys.
--
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]
