diff options
Diffstat (limited to 'MPE/flink/topology/relationship-radius-account/config/RELATIONSHIP-RADIUS-ACCOUNT')
| -rw-r--r-- | MPE/flink/topology/relationship-radius-account/config/RELATIONSHIP-RADIUS-ACCOUNT | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/MPE/flink/topology/relationship-radius-account/config/RELATIONSHIP-RADIUS-ACCOUNT b/MPE/flink/topology/relationship-radius-account/config/RELATIONSHIP-RADIUS-ACCOUNT new file mode 100644 index 0000000..60e773f --- /dev/null +++ b/MPE/flink/topology/relationship-radius-account/config/RELATIONSHIP-RADIUS-ACCOUNT @@ -0,0 +1,28 @@ +#管理kafka地址 +input.kafka.servers=192.168.20.223:9094,192.168.20.224:9094,192.168.20.225:9094 + +#hbase zookeeper地址 用于连接HBase +hbase.zookeeper.servers=192.168.20.193:2181,192.168.20.194:2181,192.168.20.195:2181 + +#--------------------------------Kafka消费组信息------------------------------# + +#kafka 接收数据topic +input.kafka.topic=RADIUS-RECORD + +#读取topic,存储该spout id的消费offset信息，可通过该拓扑命名;具体存储offset的位置，确定下次读取不重复的数据； +group.id=account-framedip-hbase-20211113-1 + +#--------------------------------topology配置------------------------------# +#ip-account对应关系表 +hbase.framedip.table.name=tsg_galaxy:relation_framedip_account + +#定位库地址 +tools.library=/data/tsg/olap/topology/data/ + +#account-ip对应关系表 +hbase.account.table.name=tsg_galaxy:relation_account_framedip + +hbase.rpc.timeout=60000 + +hbase.scan.limit=100000 + |