Skip to content
代码片段 群组 项目
未验证 提交 85ef6bc5 编辑于 作者: Steven Zhang's avatar Steven Zhang 提交者: GitHub
浏览文件

KAFKA-13769 Fix version check in SubscriptionJoinForeignProcessorSupplier (#752) (#782)


This commit changes the version check from != to > as the process method
works correctly on both version 1 and 2. != incorrectly throws on v1
records.

Co-authored-by: default avatarAlex Sorokoumov <918393+Gerrrr@users.noreply.github.com>
上级 b8f9198c
No related branches found
No related tags found
无相关合并请求
......@@ -70,7 +70,7 @@ public class SubscriptionJoinForeignProcessorSupplier<K, KO, VO>
Objects.requireNonNull(valueAndTimestamp, "This processor should never see a null newValue.");
final SubscriptionWrapper<K> value = valueAndTimestamp.value();
if (value.getVersion() != SubscriptionWrapper.CURRENT_VERSION) {
if (value.getVersion() > SubscriptionWrapper.CURRENT_VERSION) {
//Guard against modifications to SubscriptionWrapper. Need to ensure that there is compatibility
//with previous versions to enable rolling upgrades. Must develop a strategy for upgrading
//from older SubscriptionWrapper versions to newer versions.
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册