diff options
Diffstat (limited to 'properties/service_flow_config.properties')
| -rw-r--r-- | properties/service_flow_config.properties | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/properties/service_flow_config.properties b/properties/service_flow_config.properties index 97438d9..c5794bd 100644 --- a/properties/service_flow_config.properties +++ b/properties/service_flow_config.properties @@ -15,41 +15,42 @@ tools.library=D:\\workerspace\\dat nacos.server=192.168.44.12:8848 #nacos namespace -nacos.schema.namespace=prod +nacos.schema.namespace=livecharts #nacos data id -nacos.data.id=liveChart_session.json +nacos.data.id=liveChart_session_test.json #--------------------------------Kafka消费组信息------------------------------# #kafka 接收数据topic -source.kafka.topic=SESSION-RECORD +source.kafka.topic=test #补全数据 输出 topic -sink.kafka.topic=test-result +sink.kafka.topic=TRAFFIC-PROTOCOL-TEST #读取topic,存储该spout id的消费offset信息，可通过该拓扑命名;具体存储offset的位置，确定下次读取不重复的数据； -group.id=livecharts-test-20220816-1 +group.id=livecharts-test-20230327-3 #--------------------------------topology配置------------------------------# #consumer 并行度 -source.parallelism=1 +source.parallelism=3 #map函数并行度 -parse.parallelism=1 +parse.parallelism=3 #第一次窗口计算并行度 -first.window.parallelism=1 +first.window.parallelism=3 #第二次窗口计算并行度 -second.window.parallelism=1 +second.window.parallelism=3 #producer 并行度 -sink.parallelism=1 +sink.parallelism=3 #初次随机预聚合窗口时间 first.count.window.time=5 #二次聚合窗口时间 second.count.window.time=15 + |