| # |
| # Licensed to the Apache Software Foundation (ASF) under one |
| # or more contributor license agreements. See the NOTICE file |
| # distributed with this work for additional information |
| # regarding copyright ownership. The ASF licenses this file |
| # to you under the Apache License, Version 2.0 (the |
| # "License"); you may not use this file except in compliance |
| # with the License. You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, |
| # software distributed under the License is distributed on an |
| # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| # KIND, either express or implied. See the License for the |
| # specific language governing permissions and limitations |
| # under the License. |
| # |
| |
| #6-segment protocol TCP source |
| agent1.sources.tcp-source.channels = ch-msg1 ch-msg2 ch-msg3 ch-more1 ch-more2 ch-more3 ch-msg5 ch-msg6 ch-msg7 ch-msg8 ch-msg9 ch-msg10 ch-back |
| agent1.sources.tcp-source.type = org.apache.inlong.dataproxy.source.SimpleTcpSource |
| agent1.sources.tcp-source.msg-factory-name = org.apache.inlong.dataproxy.source.ServerMessageFactory |
| agent1.sources.tcp-source.message-handler-name = org.apache.inlong.dataproxy.source.ServerMessageHandler |
| agent1.sources.tcp-source.host = 0.0.0.0 |
| agent1.sources.tcp-source.port = 46801 |
| agent1.sources.tcp-source.highWaterMark=2621440 |
| agent1.sources.tcp-source.enableExceptionReturn=true |
| agent1.sources.tcp-source.max-msg-length = 524288 |
| agent1.sources.tcp-source.topic = test_token |
| agent1.sources.tcp-source.attr = m=9 |
| agent1.sources.tcp-source.connections = 5000 |
| agent1.sources.tcp-source.max-threads = 64 |
| agent1.sources.tcp-source.receiveBufferSize = 524288 |
| agent1.sources.tcp-source.sendBufferSize = 524288 |
| agent1.sources.tcp-source.custom-cp = true |
| agent1.sources.tcp-source.selector.type = org.apache.inlong.dataproxy.channel.FailoverChannelSelector |
| agent1.sources.tcp-source.selector.master = ch-msg5 ch-msg6 ch-msg7 ch-msg8 ch-msg9 |
| agent1.sources.tcp-source.selector.transfer = ch-msg5 ch-msg6 ch-msg7 ch-msg8 ch-msg9 |
| agent1.sources.tcp-source.selector.fileMetric = ch-back |
| agent1.sources.tcp-source.selector.slaMetric = ch-msg10 |
| agent1.sources.tcp-source.metric-recovery-path = ./data/metric |
| agent1.sources.tcp-source.metric-agent-port=8003 |
| agent1.sources.tcp-source.metric-cache-size=10000 |
| agent1.sources.tcp-source.set=10 |
| agent1.sources.tcp-source.old-metric-on=true |
| agent1.sources.tcp-source.new-metric-on=true |
| agent1.sources.tcp-source.metric_topic_prefix=manager_tmertic |
| |
| agent1.channels.ch-back.type = memory |
| agent1.channels.ch-back.capacity = 10000000 |
| agent1.channels.ch-back.keep-alive = 0 |
| agent1.channels.ch-back.transactionCapacity = 200 |
| |
| agent1.channels.ch-msg1.type = memory |
| agent1.channels.ch-msg1.capacity = 200000 |
| agent1.channels.ch-msg1.keep-alive = 0 |
| agent1.channels.ch-msg1.transactionCapacity = 200 |
| |
| agent1.channels.ch-msg2.type = memory |
| agent1.channels.ch-msg2.capacity = 200000 |
| agent1.channels.ch-msg2.keep-alive = 0 |
| agent1.channels.ch-msg2.transactionCapacity = 200 |
| |
| agent1.channels.ch-msg3.type = memory |
| agent1.channels.ch-msg3.capacity = 200000 |
| agent1.channels.ch-msg3.keep-alive = 0 |
| agent1.channels.ch-msg3.transactionCapacity = 200 |
| |
| agent1.channels.ch-msg5.type = file |
| agent1.channels.ch-msg5.capacity = 100000000 |
| agent1.channels.ch-msg5.maxFileSize = 1073741824 |
| agent1.channels.ch-msg5.minimumRequiredSpace = 1073741824 |
| agent1.channels.ch-msg5.checkpointDir = ./data/file/ch-msg5/check |
| agent1.channels.ch-msg5.dataDirs = ./data/file/ch-msg5/data |
| agent1.channels.ch-msg5.fsyncPerTransaction = false |
| agent1.channels.ch-msg5.fsyncInterval = 5 |
| |
| agent1.channels.ch-msg6.type = file |
| agent1.channels.ch-msg6.capacity = 100000000 |
| agent1.channels.ch-msg6.maxFileSize = 1073741824 |
| agent1.channels.ch-msg6.minimumRequiredSpace = 1073741824 |
| agent1.channels.ch-msg6.checkpointDir = ./data/file/ch-msg6/check |
| agent1.channels.ch-msg6.dataDirs = ./data/file/ch-msg6/data |
| agent1.channels.ch-msg6.fsyncPerTransaction = false |
| agent1.channels.ch-msg6.fsyncInterval = 5 |
| |
| agent1.channels.ch-msg7.type = file |
| agent1.channels.ch-msg7.capacity = 100000000 |
| agent1.channels.ch-msg7.maxFileSize = 1073741824 |
| agent1.channels.ch-msg7.minimumRequiredSpace = 1073741824 |
| agent1.channels.ch-msg7.checkpointDir = ./data/file/ch-msg7/check |
| agent1.channels.ch-msg7.dataDirs = ./data/file/ch-msg7/data |
| agent1.channels.ch-msg7.fsyncPerTransaction = false |
| agent1.channels.ch-msg7.fsyncInterval = 5 |
| |
| agent1.channels.ch-msg8.type = file |
| agent1.channels.ch-msg8.capacity = 100000000 |
| agent1.channels.ch-msg8.maxFileSize = 1073741824 |
| agent1.channels.ch-msg8.minimumRequiredSpace = 1073741824 |
| agent1.channels.ch-msg8.checkpointDir = ./data/file/ch-msg8/check |
| agent1.channels.ch-msg8.dataDirs = ./data/file/ch-msg8/data |
| agent1.channels.ch-msg8.fsyncPerTransaction = false |
| agent1.channels.ch-msg8.fsyncInterval = 5 |
| |
| agent1.channels.ch-msg9.type = file |
| agent1.channels.ch-msg9.capacity = 100000000 |
| agent1.channels.ch-msg9.maxFileSize = 1073741824 |
| agent1.channels.ch-msg9.minimumRequiredSpace = 1073741824 |
| agent1.channels.ch-msg9.checkpointDir = ./data/file/ch-msg9/check |
| agent1.channels.ch-msg9.dataDirs = ./data/file/ch-msg9/data |
| agent1.channels.ch-msg9.fsyncPerTransaction = false |
| agent1.channels.ch-msg9.fsyncInterval = 5 |
| |
| agent1.channels.ch-msg10.type = file |
| agent1.channels.ch-msg10.capacity = 100000000 |
| agent1.channels.ch-msg10.maxFileSize = 1073741824 |
| agent1.channels.ch-msg10.minimumRequiredSpace = 1073741824 |
| agent1.channels.ch-msg10.checkpointDir = ./data/file/ch-msg10/check |
| agent1.channels.ch-msg10.dataDirs = ./data/file/ch-msg10/data |
| agent1.channels.ch-msg10.fsyncPerTransaction = false |
| agent1.channels.ch-msg10.fsyncInterval = 5 |
| |
| agent1.sinks.meta-sink-more1.channel = ch-msg1 |
| agent1.sinks.meta-sink-more1.type = org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sinks.meta-sink-more2.channel = ch-more2 |
| agent1.sinks.meta-sink-more2.type =org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sinks.meta-sink-more3.channel = ch-more3 |
| agent1.sinks.meta-sink-more3.type =org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sinks.meta-sink-most1.channel = ch-most1 |
| agent1.sinks.meta-sink-most1.type =org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sinks.meta-sink-most2.channel = ch-most2 |
| agent1.sinks.meta-sink-most2.type =org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sinks.meta-sink-most3.channel = ch-most3 |
| agent1.sinks.meta-sink-most3.type =org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sinks.meta-sink-msg1.channel = ch-msg1 |
| agent1.sinks.meta-sink-msg1.type =org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sinks.meta-sink-msg2.channel = ch-msg2 |
| agent1.sinks.meta-sink-msg2.type =org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sinks.meta-sink-msg3.channel = ch-msg3 |
| agent1.sinks.meta-sink-msg3.type =org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sinks.meta-sink-msg8.channel = ch-msg1 |
| agent1.sinks.meta-sink-msg8.type =org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sinks.meta-sink-msg8.channel = ch-back |
| agent1.sinks.meta-sink-msg8.type =org.apache.inlong.dataproxy.sink.TubeSink |
| |
| agent1.sources = tcp-source |
| agent1.channels = ch-back ch-msg1 ch-msg2 ch-msg3 ch-msg5 ch-msg6 ch-msg7 ch-msg8 ch-msg9 ch-msg10 |
| agent1.sinks = meta-sink-msg1 meta-sink-msg2 meta-sink-msg3 meta-sink-msg5 meta-sink-msg6 meta-sink-msg7 meta-sink-msg8 meta-sink-transfer |
| |
