增加京东主题，利用flink合流，一次性处理两个主题的数据

src/main/resources/app.properties

 # kafka 主题
-kafka.topic=tb_item_list
-#kafka.topic = jdgoods
+kafka.jd.topic=jd_item_list
+kafka.tb.topic=tb_item_list
 # kafka集群
-kafka.cluster=qmbigdata01:9092,qmbigdata02:9092,qmbigdata03:9092,qmbigdata04:9092,qmbigdata05:9092
-#kafka.cluster=8.135.22.177:9092,8.135.53.75:9092,8.135.100.29:9092,8.135.58.206:9092,47.119.179.1:9092
+#kafka.cluster=qmbigdata01:9092,qmbigdata02:9092,qmbigdata03:9092,qmbigdata04:9092,qmbigdata05:9092
+kafka.cluster=8.135.22.177:9092,8.135.53.75:9092,8.135.100.29:9092,8.135.58.206:9092,47.119.179.1:9092
 # kafka消费者组
-kafka.consumer.group=tb-goods-group
+kafka.tb.consumer.group=tb-goods-group
+kafka.jd.consumer.group=jd-goods-group
 # kafka key 序列化
 kafka.consumer.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
 # kafka values 序列化
@@ -16,8 +17,8 @@ kafka.consumer.offset.commit.auto=true
 # 算法分词接口
 nlp.interface.url=http://bigdata.xiaomanxiong.com/nlp
 # es机器
-es.cluster=qmbigdata01:9200,qmbigdata02:9200,qmbigdata03:9200,qmbigdata04:9200,qmbigdata05:9200
+#es.cluster=qmbigdata02:9200,qmbigdata03:9200,qmbigdata04:9200,qmbigdata05:9200
 # 本地测试
-#es.cluster=localhost:9200
+es.cluster=localhost:9200
 # es索引
 es.indices=goods_v2
\ No newline at end of file