Gerrrr commented on code in PR #11945:
URL: https://github.com/apache/kafka/pull/11945#discussion_r850652693
##########
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java:
##########
@@ -21,22 +21,30 @@
import java.util.Arrays;
public class SubscriptionResponseWrapper<FV> {
- final static byte CURRENT_VERSION = 0x00;
+ final static byte CURRENT_VERSION = 0x01;
+ // 0x00
private final long[] originalValueHash;
private final FV foreignValue;
private final byte version;
+ // 0x01
+ private final Integer primaryPartition;
Review Comment:
Good catch! Done in f7f9181ec3312b21a3534919819ccd02dfdcbc74.
--
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]
