kafka消费者代码

wangzhiwubigdata · Jul 11, 2020 · ea76f1c · ea76f1c
1 parent b67e8e5
commit ea76f1c
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/main/java/org/myorg/quickstart/Distinct20/RedisSinkDistinct.java b/src/main/java/org/myorg/quickstart/Distinct20/RedisSinkDistinct.java
@@ -4,9 +4,7 @@
 import org.apache.flink.api.java.tuple.Tuple2;
 import org.apache.flink.util.Collector;
 
-/**
- * Created by wangchangye on 2020/6/21.
- */
+
 public class RedisSinkDistinct implements FlatMapFunction<Tuple2<String, Integer>, Tuple2<String, Integer>> {
     @Override
     public void flatMap(Tuple2<String, Integer> value, Collector<Tuple2<String, Integer>> out) throws Exception {