Removed javadoc issues
diff --git a/src/test/java/org/apache/geode/kafka/GeodeAsSinkDUnitTest.java b/src/test/java/org/apache/geode/kafka/GeodeAsSinkDUnitTest.java
index 65747e2..4dc0bb7 100644
--- a/src/test/java/org/apache/geode/kafka/GeodeAsSinkDUnitTest.java
+++ b/src/test/java/org/apache/geode/kafka/GeodeAsSinkDUnitTest.java
@@ -102,7 +102,7 @@
String sinkTopic = "SINK_TOPIC_" + testIdentifier;
String sourceTopic = "SOURCE_TOPIC_" + testIdentifier;
- /**
+ /*
* Start the Apache Geode cluster and create the source and sink regions.
* Create a Apache Geode client which inserts data into the source
*/
@@ -114,7 +114,7 @@
});
- /**
+ /*
* Start the Kafka Cluster, workers and the topic to which the Apache Geode will connect as
* a source
*/
diff --git a/src/test/java/org/apache/geode/kafka/GeodeAsSourceDUnitTest.java b/src/test/java/org/apache/geode/kafka/GeodeAsSourceDUnitTest.java
index 018a9b9..108d86a 100644
--- a/src/test/java/org/apache/geode/kafka/GeodeAsSourceDUnitTest.java
+++ b/src/test/java/org/apache/geode/kafka/GeodeAsSourceDUnitTest.java
@@ -114,7 +114,7 @@
String sinkTopic = "SINK_TOPIC_" + testIdentifier;
String sourceTopic = "SOURCE_TOPIC_" + testIdentifier;
- /**
+ /*
* Start the Apache Geode cluster and create the source and sink regions.
* Create a Apache Geode client which inserts data into the source
*/
@@ -129,7 +129,7 @@
.create(sourceRegion);
});
- /**
+ /*
* Start the Kafka Cluster, workers and the topic to which the Apache Geode will connect as
* a source
*/
