From 77f7d99fcb0e43ade3be395b20947ba60a4dffbb Mon Sep 17 00:00:00 2001 From: qidaijie Date: Tue, 28 Dec 2021 10:48:20 +0300 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4subscriberid=E8=8E=B7?= =?UTF-8?q?=E5=8F=96=E6=96=B9=E5=BC=8F=E5=8F=98=E6=9B=B4=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- properties/service_flow_config.properties | 2 +- src/main/java/com/zdjizhi/utils/hbase/HBaseUtils.java | 2 -- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/properties/service_flow_config.properties b/properties/service_flow_config.properties index 8acb476..4480bc9 100644 --- a/properties/service_flow_config.properties +++ b/properties/service_flow_config.properties @@ -1,7 +1,7 @@ #--------------------------------地址配置------------------------------# #管理kafka地址 -source.kafka.servers=10.224.11.11 +source.kafka.servers=10.224.11.14:9094 #管理输出kafka地址 sink.kafka.servers=10.224.11.14:9095,10.224.11.15:9095,10.224.11.16:9095,10.224.11.17:9095,10.224.11.18:9095,10.224.11.19:9095,10.224.11.20:9095,10.224.11.21:9095,10.224.11.22:9095,10.224.11.23:9095 diff --git a/src/main/java/com/zdjizhi/utils/hbase/HBaseUtils.java b/src/main/java/com/zdjizhi/utils/hbase/HBaseUtils.java index de5e149..6aa904f 100644 --- a/src/main/java/com/zdjizhi/utils/hbase/HBaseUtils.java +++ b/src/main/java/com/zdjizhi/utils/hbase/HBaseUtils.java @@ -4,8 +4,6 @@ import cn.hutool.log.Log; import cn.hutool.log.LogFactory; import com.zdjizhi.common.FlowWriteConfig; import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.hbase.Cell; -import org.apache.hadoop.hbase.CellUtil; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.*;