Skip to content

Commit 7ceba9c

Browse files
author
Julien Ruaux
committed
test: Fixed version test
1 parent 82d10dc commit 7ceba9c

File tree

2 files changed

+7
-6
lines changed

2 files changed

+7
-6
lines changed

src/test/unit/java/com/redis/kafka/connect/RedisSinkConnectorTest.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,13 @@
11
package com.redis.kafka.connect;
22

3-
import com.redis.kafka.connect.sink.RedisSinkTask;
3+
import java.util.HashMap;
4+
45
import org.apache.kafka.common.config.ConfigDef;
5-
import org.apache.kafka.common.utils.AppInfoParser;
66
import org.junit.jupiter.api.Assertions;
77
import org.junit.jupiter.api.Test;
88

9-
import java.util.HashMap;
9+
import com.redis.kafka.connect.common.VersionProvider;
10+
import com.redis.kafka.connect.sink.RedisSinkTask;
1011

1112
class RedisSinkConnectorTest {
1213

@@ -32,7 +33,7 @@ void testTaskConfigs() {
3233

3334
@Test
3435
void testVersion() {
35-
Assertions.assertEquals(AppInfoParser.getVersion(), new RedisSinkConnector().version());
36+
Assertions.assertEquals(VersionProvider.getVersion(), new RedisSinkConnector().version());
3637
}
3738

3839
}

src/test/unit/java/com/redis/kafka/connect/RedisSourceConnectorTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,10 +8,10 @@
88

99
import org.apache.kafka.common.config.ConfigDef;
1010
import org.apache.kafka.common.config.ConfigValue;
11-
import org.apache.kafka.common.utils.AppInfoParser;
1211
import org.junit.jupiter.api.Assertions;
1312
import org.junit.jupiter.api.Test;
1413

14+
import com.redis.kafka.connect.common.VersionProvider;
1515
import com.redis.kafka.connect.source.RedisSourceConfig;
1616
import com.redis.kafka.connect.source.RedisSourceTask;
1717

@@ -62,7 +62,7 @@ void testKeyReaderTaskConfig() {
6262

6363
@Test
6464
void testVersion() {
65-
Assertions.assertEquals(AppInfoParser.getVersion(), new RedisSourceConnector().version());
65+
Assertions.assertEquals(VersionProvider.getVersion(), new RedisSourceConnector().version());
6666
}
6767

6868
@Test

0 commit comments

Comments
 (0)