bump dependency versions (#98)

* bump dependency versions

* Update test for new version of kafka

Author: Crim

CHANGELOG.md

@@ -10,6 +10,7 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 - Added ability to modify topic configuration via the UI.
 - Various UI usability improvements.
 - Updated SpringBoot framework from 1.5.x to 2.0.5.
+- Updates Kafka Client from 0.11.0.2 to 1.1.1.
 
 ### Breaking Changes
 

dev-cluster/pom.xml

@@ -92,7 +92,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-deploy-plugin</artifactId>
-                <version>2.7</version>
+                <version>2.8.2</version>
                 <configuration>
                     <skip>true</skip>
                 </configuration>

dev-cluster/src/main/java/org/sourcelab/kafka/devcluster/DevCluster.java

@@ -25,6 +25,7 @@
 package org.sourcelab.kafka.devcluster;
 
 import com.salesforce.kafka.test.KafkaTestCluster;
+import com.salesforce.kafka.test.KafkaTestUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -58,6 +59,16 @@ public static void main(final String[] args) throws Exception {
         // Start the cluster.
         kafkaTestCluster.start();
 
+        // Create a topic
+        final String topicName = "TestTopicA";
+        final KafkaTestUtils utils = new KafkaTestUtils(kafkaTestCluster);
+        utils.createTopic(topicName, clusterSize, (short) clusterSize);
+
+        // Publish some data into that topic
+        for (int partition = 0; partition < clusterSize; partition++) {
+            utils.produceRecords(1000, topicName, partition);
+        }
+
         kafkaTestCluster
             .getKafkaBrokers()
             .stream()

kafka-webview-ui/pom.xml

@@ -32,7 +32,7 @@
         <java.version>1.8</java.version>
         <bootstrap.version>4.0.0-beta</bootstrap.version>
         <thymeleaf.version>3.0.9.RELEASE</thymeleaf.version>
-        <kafka.version>0.11.0.2</kafka.version>
+        <kafka.version>1.1.1</kafka.version>
     </properties>
 
     <dependencies>
@@ -182,7 +182,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-compiler-plugin</artifactId>
-                <version>3.6.1</version>
+                <version>3.8.0</version>
                 <configuration>
                     <source>1.8</source>
                     <target>1.8</target>
@@ -193,7 +193,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-dependency-plugin</artifactId>
-                <version>3.0.1</version>
+                <version>3.1.1</version>
                 <executions>
                     <execution>
                         <id>copy-dependencies</id>
@@ -206,7 +206,7 @@
             <!-- Clean dist directory for frontend -->
             <plugin>
                 <artifactId>maven-clean-plugin</artifactId>
-                <version>3.0.0</version>
+                <version>3.1.0</version>
                 <configuration>
                     <filesets>
                         <fileset>
@@ -278,7 +278,7 @@
             <!-- Copies frontend dist over to resources directory -->
             <plugin>
                 <artifactId>maven-resources-plugin</artifactId>
-                <version>2.7</version>
+                <version>3.1.0</version>
                 <executions>
                     <execution>
                         <id>copy gulp dist files to static</id>
@@ -303,7 +303,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-assembly-plugin</artifactId>
-                <version>2.5.1</version>
+                <version>3.1.0</version>
                 <configuration>
                     <!-- Configures the used assembly descriptor -->
                     <descriptors>

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

@@ -286,8 +286,8 @@ public void testModifyingATopic() {
         final String topicName = "TestTopic-" + System.currentTimeMillis();
 
         // Define the values we want to modify
-        final String configName1 = "flush.messages";
-        final String newConfigValue1 = "0";
+        final String configName1 = "cleanup.policy";
+        final String newConfigValue1 = "compact";
 
         final String configName2 = "max.message.bytes";
         final String newConfigValue2 = "1024";