Fix class name and pom dependencies

Author: CuriousVini

kafka-plugins-0.10/pom.xml

@@ -20,14 +20,9 @@
       <version>${project.parent.version}</version>
     </dependency>
     <dependency>
-      <groupId>io.cdap.plugin</groupId>
-      <artifactId>format-common</artifactId>
-      <version>${cdap.plugin.version}</version>
-    </dependency>
-    <dependency>
-      <groupId>io.cdap.plugin</groupId>
-      <artifactId>format-avro</artifactId>
-      <version>${cdap.plugin.version}</version>
+      <groupId>org.apache.avro</groupId>
+      <artifactId>avro</artifactId>
+      <version>${avro.version}</version>
     </dependency>
     <dependency>
       <groupId>org.apache.kafka</groupId>

kafka-plugins-0.10/src/main/java/io/cdap/plugin/source/KafkaStreamingSource.java

@@ -69,6 +69,6 @@ public JavaDStream<StructuredRecord> getStream(StreamingContext context) throws
     collector.getOrThrowException();
 
     context.registerLineage(conf.referenceName);
-    return KafkaStreaminSourceUtil.getStructuredRecordJavaDStream(context, conf, collector);
+    return KafkaStreamingSourceUtil.getStructuredRecordJavaDStream(context, conf, collector);
   }
 }

kafka-plugins-0.10/src/main/java/io/cdap/plugin/source/KafkaStreaminSourceUtil.java renamed to kafka-plugins-0.10/src/main/java/io/cdap/plugin/source/KafkaStreamingSourceUtil.java

@@ -62,8 +62,8 @@
  * This class contains methods for {@link KafkaStreamingSource} that require spark classes because during validation
  * spark classes are not available. Refer CDAP-15912 for more information.
  */
-final class KafkaStreaminSourceUtil {
-  private static final Logger LOG = LoggerFactory.getLogger(KafkaStreaminSourceUtil.class);
+final class KafkaStreamingSourceUtil {
+  private static final Logger LOG = LoggerFactory.getLogger(KafkaStreamingSourceUtil.class);
 
   /**
    * Returns {@link JavaDStream} for {@link KafkaStreamingSource}.
@@ -284,7 +284,7 @@ protected void addMessage(StructuredRecord.Builder builder, String messageField,
     }
   }
 
-  private KafkaStreaminSourceUtil() {
+  private KafkaStreamingSourceUtil() {
     // no-op
   }
 }

kafka-plugins-0.8/pom.xml

@@ -20,14 +20,9 @@
       <version>${project.parent.version}</version>
     </dependency>
     <dependency>
-      <groupId>io.cdap.plugin</groupId>
-      <artifactId>format-common</artifactId>
-      <version>${cdap.plugin.version}</version>
-    </dependency>
-    <dependency>
-      <groupId>io.cdap.plugin</groupId>
-      <artifactId>format-avro</artifactId>
-      <version>${cdap.plugin.version}</version>
+      <groupId>org.apache.avro</groupId>
+      <artifactId>avro</artifactId>
+      <version>${avro.version}</version>
     </dependency>
     <dependency>
       <groupId>org.apache.kafka</groupId>

pom.xml

@@ -84,6 +84,7 @@
     <hadoop.version>2.3.0</hadoop.version>
     <netty.version>4.1.16.Final</netty.version>
     <netty-http.version>1.3.0</netty-http.version>
+    <avro.version>1.8.2</avro.version>
     <main.basedir>${project.basedir}</main.basedir>
   </properties>
 
@@ -121,16 +122,6 @@
       <artifactId>cdap-formats</artifactId>
       <version>${cdap.version}</version>
     </dependency>
-    <dependency>
-      <groupId>io.cdap.plugin</groupId>
-      <artifactId>format-common</artifactId>
-      <version>${cdap.plugin.version}</version>
-    </dependency>
-    <dependency>
-      <groupId>io.cdap.plugin</groupId>
-      <artifactId>format-avro</artifactId>
-      <version>${cdap.plugin.version}</version>
-    </dependency>
     <dependency>
       <groupId>io.cdap.cdap</groupId>
       <artifactId>hydrator-test</artifactId>