diff options
| author | wangchengcheng <[email protected]> | 2023-05-22 16:23:03 +0800 |
|---|---|---|
| committer | wangchengcheng <[email protected]> | 2023-05-22 16:23:03 +0800 |
| commit | 578bcbbb2a0c1d0e5970df6b46f2764e25d915f2 (patch) | |
| tree | f60b7cf6bb2c16e99064a29016f27859c7f14acb /properties | |
| parent | 5e21ca97f4896dd2f875c72cb9d771e632d6f90d (diff) | |
Diffstat (limited to 'properties')
| -rw-r--r-- | properties/default_config.properties | 2 | ||||
| -rw-r--r-- | properties/service_flow_config.properties | 8 |
2 files changed, 5 insertions, 5 deletions
diff --git a/properties/default_config.properties b/properties/default_config.properties index 976e210..c25005c 100644 --- a/properties/default_config.properties +++ b/properties/default_config.properties @@ -42,4 +42,4 @@ buffer.timeout=100 -random.range.num=20 +random.range.num=1 diff --git a/properties/service_flow_config.properties b/properties/service_flow_config.properties index d7ac7b1..8fa687d 100644 --- a/properties/service_flow_config.properties +++ b/properties/service_flow_config.properties @@ -1,16 +1,16 @@ #--------------------------------地址配置------------------------------# #管理kafka地址 -source.kafka.servers=192.168.45.102:9094 +source.kafka.servers=192.168.44.12:9094 #管理输出kafka地址 -sink.kafka.servers=192.168.45.102:9094 +sink.kafka.servers=192.168.44.12:9094 tools.library=D:\\workerspace\\dat\\ #--------------------------------Kafka消费配置(session)------------------------------# #已关闭会话 -session.source.kafka.topic=SESSION-RECORD +session.source.kafka.topic=test #读取topic,存储该spout id的消费offset信息，可通过该拓扑命名;具体存储offset的位置，确定下次读取不重复的数据； session.group.id=session-record-app-protocol-stat-traffic-agent-2 @@ -22,7 +22,7 @@ session.source.parallelism=1 #--------------------------------Kafka消费配置(interim Session)------------------------------# #过渡会话 -interim.session.source.kafka.topic=SESSION-RECORD +interim.session.source.kafka.topic=test-11 #读取topic,存储该spout id的消费offset信息，可通过该拓扑命名;具体存储offset的位置，确定下次读取不重复的数据； |