move to latest kafka client

Author: brianhks

deploy.sh

@@ -0,0 +1,2 @@
+mvn clean package; mv target/kafka-monitor-1.0-SNAPSHOT.jar target/dependency/
+

pom.xml

@@ -61,7 +61,7 @@
 		<dependency>
 			<groupId>org.apache.kafka</groupId>
 			<artifactId>kafka-clients</artifactId>
-			<version>0.10.2.1</version>
+			<version>2.1.0</version>
 			<exclusions>
 				<exclusion>
 					<artifactId>slf4j-api</artifactId>

src/main/java/org/kairosdb/kafka/monitor/KafkaModule.java

@@ -6,7 +6,6 @@
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.common.serialization.Serdes;
-import org.apache.kafka.streams.StreamsConfig;
 
 import javax.inject.Named;
 import java.util.Properties;

src/main/java/org/kairosdb/kafka/monitor/OffsetListenerService.java

@@ -214,6 +214,7 @@ private Map<Integer, Long> getLatestTopicOffsets(String topic)
 
 	private void postEvent(DataPointEvent event)
 	{
+
 		//Metrics are kinda wonky the first time through so we skip those.
 		if (m_runCounter != 0)
 			m_publisher.post(event);