From f0792db6b364a44d2d1caedfff2c782aee0168fe Mon Sep 17 00:00:00 2001 From: zengqiao Date: Wed, 24 Aug 2022 21:27:04 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=BC=E5=AE=B90.10.2=E7=89=88=E6=9C=ACoffse?= =?UTF-8?q?t=E4=BF=A1=E6=81=AF=E7=9A=84=E8=8E=B7=E5=8F=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../km/core/service/partition/impl/PartitionServiceImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java index 1102949b..44b2df37 100644 --- a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java +++ b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java @@ -85,8 +85,8 @@ public class PartitionServiceImpl extends BaseVersionControlService implements P @PostConstruct private void init() { - registerVCHandler(PARTITION_OFFSET_GET, V_0_10_0_0, V_0_10_2_0, "getPartitionOffsetFromKafkaConsumerClient", this::getPartitionOffsetFromKafkaConsumerClient); - registerVCHandler(PARTITION_OFFSET_GET, V_0_10_2_0, V_MAX, "getPartitionOffsetFromKafkaAdminClient", this::getPartitionOffsetFromKafkaAdminClient); + registerVCHandler(PARTITION_OFFSET_GET, V_0_10_0_0, V_0_11_0_0, "getPartitionOffsetFromKafkaConsumerClient", this::getPartitionOffsetFromKafkaConsumerClient); + registerVCHandler(PARTITION_OFFSET_GET, V_0_11_0_0, V_MAX, "getPartitionOffsetFromKafkaAdminClient", this::getPartitionOffsetFromKafkaAdminClient); } @Override