Update KafkaJunit dependency (#68)

Author: Crim

kafka-webview-ui/pom.xml

@@ -134,7 +134,7 @@
         <dependency>
             <groupId>com.salesforce.kafka.test</groupId>
             <artifactId>kafka-junit4</artifactId>
-            <version>2.2.0</version>
+            <version>3.0.0</version>
             <scope>test</scope>
         </dependency>
         <dependency>

kafka-webview-ui/src/test/java/org/sourcelab/kafka/webview/ui/manager/kafka/KafkaConsumerFactoryTest.java

@@ -65,8 +65,8 @@ public void testBasicConsumerMultiplePartitions() {
         // Create a topic with 2 partitions, (partitionId 0, 1)
         final String topicName = "TestTopic";
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topicName, 2);
+            .getKafkaTestUtils()
+            .createTopic(topicName, 2, (short) 1);
 
         // Produce 10 records into partition 0 of topic.
         sharedKafkaTestResource
@@ -126,8 +126,8 @@ public void testBasicConsumerExcludePartitions() {
         // Create a topic with 2 partitions, (partitionId 0, 1)
         final String topicName = "TestTopic";
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topicName, 2);
+            .getKafkaTestUtils()
+            .createTopic(topicName, 2, (short) 1);
 
         // Produce 10 records into partition 0 of topic.
         sharedKafkaTestResource
@@ -191,8 +191,8 @@ public void testBasicConsumerWithRecordFilter() throws InterruptedException {
         // Create a topic with 2 partitions, (partitionId 0, 1)
         final String topicName = "TestTopic";
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topicName, 2);
+            .getKafkaTestUtils()
+            .createTopic(topicName, 2, (short) 1);
 
         // Produce 10 records into partition 0 of topic.
         sharedKafkaTestResource
@@ -263,8 +263,8 @@ public void testDeserializerOptions() throws InterruptedException {
         // Create a topic with 1 partitions, (partitionId 0)
         final String topicName = "TestTopic" + System.currentTimeMillis();
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topicName, 1);
+            .getKafkaTestUtils()
+            .createTopic(topicName, 1, (short) 1);
 
         // Create factory
         final KafkaConsumerFactory kafkaConsumerFactory = new KafkaConsumerFactory("not/used", "TestPrefix");

kafka-webview-ui/src/test/java/org/sourcelab/kafka/webview/ui/manager/kafka/KafkaOperationsTest.java

@@ -63,12 +63,12 @@ public void testGetAvailableTopics() {
 
         // Create two topics
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topic1, 2);
+            .getKafkaTestUtils()
+            .createTopic(topic1, 2, (short) 1);
 
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topic2, 1);
+            .getKafkaTestUtils()
+            .createTopic(topic2, 1, (short) 1);
 
         final ClusterConfig clusterConfig = ClusterConfig.newBuilder()
             .withBrokerHosts(sharedKafkaTestResource.getKafkaConnectString())
@@ -140,12 +140,12 @@ public void testGetTopicDetails() {
 
         // Create two topics
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topic1, 2);
+            .getKafkaTestUtils()
+            .createTopic(topic1, 2, (short) 1);
 
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topic2, 1);
+            .getKafkaTestUtils()
+            .createTopic(topic2, 1, (short) 1);
 
         final ClusterConfig clusterConfig = ClusterConfig.newBuilder()
             .withBrokerHosts(sharedKafkaTestResource.getKafkaConnectString())
@@ -196,12 +196,12 @@ public void testGetTopicConfig() {
 
         // Create two topics
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topic1, 2);
+            .getKafkaTestUtils()
+            .createTopic(topic1, 2, (short) 1);
 
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topic2, 1);
+            .getKafkaTestUtils()
+            .createTopic(topic2, 1, (short) 1);
 
         final ClusterConfig clusterConfig = ClusterConfig.newBuilder()
             .withBrokerHosts(sharedKafkaTestResource.getKafkaConnectString())

kafka-webview-ui/src/test/java/org/sourcelab/kafka/webview/ui/manager/kafka/WebKafkaConsumerFactoryTest.java

@@ -67,12 +67,12 @@ public void beforeTest() {
 
         // Create topics
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topic1, 2);
+            .getKafkaTestUtils()
+            .createTopic(topic1, 2, (short) 1);
 
         sharedKafkaTestResource
-            .getKafkaTestServer()
-            .createTopic(topic2, 2);
+            .getKafkaTestUtils()
+            .createTopic(topic2, 2, (short) 1);
 
         // Publish data into topics
         sharedKafkaTestResource