Skip to content

Commit 2f0ac19

Browse files
committed
Fixed constants import
1 parent c865308 commit 2f0ac19

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/test/java/tutorial/buildon/aws/streaming/kafka/MyFirstConnectorTest.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,8 @@
1010
import static org.junit.jupiter.api.Assertions.assertEquals;
1111
import static org.junit.jupiter.api.Assertions.assertThrows;
1212

13+
import static tutorial.buildon.aws.streaming.kafka.MyFirstKafkaConnectorConfig.*;
14+
1315
public class MyFirstConnectorTest {
1416

1517
@Test
@@ -26,10 +28,11 @@ public void checkClassTask() {
2628

2729
@Test
2830
public void checkSpecialCircumstance() {
31+
final String value = "sameValue";
2932
assertThrows(ConnectException.class, () -> {
3033
Map<String, String> props = new HashMap<>();
31-
props.put("first.nonrequired.param", "sameValue");
32-
props.put("second.nonrequired.param", "sameValue");
34+
props.put(FIRST_NONREQUIRED_PARAM_CONFIG, value);
35+
props.put(SECOND_NONREQUIRED_PARAM_CONFIG, value);
3336
new MyFirstKafkaConnector().validate(props);
3437
});
3538
}

0 commit comments

Comments
 (0)