diff options
Diffstat (limited to 'properties/service_flow_config.properties')
| -rw-r--r-- | properties/service_flow_config.properties | 8 |
1 files changed, 4 insertions, 4 deletions
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的位置，确定下次读取不重复的数据； |