diff options
Diffstat (limited to 'properties/service_flow_config.properties')
| -rw-r--r-- | properties/service_flow_config.properties | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/properties/service_flow_config.properties b/properties/service_flow_config.properties new file mode 100644 index 0000000..939b6d8 --- /dev/null +++ b/properties/service_flow_config.properties @@ -0,0 +1,45 @@ +#--------------------------------地址配置------------------------------# + +#管理kafka地址 +input.kafka.servers=192.168.44.12:9092 + +#管理输出kafka地址 +output.kafka.servers=192.168.44.12:9092 + +#--------------------------------HTTP------------------------------# +#定位库地址 +tools.library=D:\\K18-Phase2\\tsgSpace\\dat\\tsg\\ + +#网关的schema位置 +schema.http=http://192.168.44.67:9999/metadata/schema/v1/fields/voip_record_log + +#--------------------------------Kafka消费组信息------------------------------# + +#kafka 接收数据topic +input.kafka.topic=VOIP-RECORD + +#补全数据 输出 topic +output.kafka.topic=VOIP-CONVERSATION-RECORD + +#读取topic,存储该spout id的消费offset信息，可通过该拓扑命名;具体存储offset的位置，确定下次读取不重复的数据； +group.id=voip-relation-log-20210625-1 + +#生产者压缩模式 none or snappy +producer.kafka.compression.type=none + +#生产者ack +producer.ack=1 + +#--------------------------------topology配置------------------------------# + +#map函数并行度 +window.parallelism=1 + +#voip日志对准窗口时间 seconds +voip.calibration.window.time=15 + +#单向流对准窗口时间 seconds +one.sided.window.time=60 + +#voip二次对准时间 seconds +sec.combine.sr.cache.secs=300
\ No newline at end of file |