| # |
| # 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. |
| # |
| |
| # The configuration file needs to define the sources, |
| # the channels and the sinks. |
| # Sources, channels and sinks are defined per agent, |
| # in this case called 'agent' |
| |
| agent1.sources = tcp-source |
| agent1.channels = ch-msg1 |
| agent1.sinks = tube-sink-msg1 |
| |
| agent1.sources.tcp-source.channels = ch-msg1 |
| agent1.sources.tcp-source.type = org.apache.inlong.audit.source.SimpleTcpSource |
| agent1.sources.tcp-source.msg-factory-name = org.apache.inlong.audit.source.ServerMessageFactory |
| agent1.sources.tcp-source.message-handler-name = org.apache.inlong.audit.source.ServerMessageHandler |
| agent1.sources.tcp-source.host = 0.0.0.0 |
| agent1.sources.tcp-source.port = 10081 |
| 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.audit.channel.FailoverChannelSelector |
| agent1.sources.tcp-source.selector.master = ch-msg1 |
| agent1.sources.tcp-source.metric-recovery-path=./data/recovery |
| agent1.sources.tcp-source.set=10 |
| |
| agent1.channels.ch-msg1.type = memory |
| agent1.channels.ch-msg1.capacity = 10000 |
| agent1.channels.ch-msg1.keep-alive = 0 |
| agent1.channels.ch-msg1.transactionCapacity = 200 |
| |
| agent1.channels.ch-msg2.type = file |
| agent1.channels.ch-msg2.capacity = 100000000 |
| agent1.channels.ch-msg2.maxFileSize = 1073741824 |
| agent1.channels.ch-msg2.minimumRequiredSpace = 1073741824 |
| agent1.channels.ch-msg2.checkpointDir =./data/file/ch-msg2/check |
| agent1.channels.ch-msg2.dataDirs =./data/file/ch-msg2/data |
| agent1.channels.ch-msg2.fsyncPerTransaction = false |
| agent1.channels.ch-msg2.fsyncInterval = 10 |
| |
| agent1.sinks.tube-sink-msg1.channel = ch-msg1 |
| agent1.sinks.tube-sink-msg1.type = org.apache.inlong.audit.sink.TubeSink |
| agent1.sinks.tube-sink-msg1.master-host-port-list = localhost:8715 |
| agent1.sinks.tube-sink-msg1.topic = inlong-audit |
| agent1.sinks.tube-sink-msg1.send_timeout = 30000 |
| agent1.sinks.tube-sink-msg1.stat-interval-sec = 60 |
| agent1.sinks.tube-sink-msg1.thread-num = 8 |
| agent1.sinks.tube-sink-msg1.client-id-cache = true |
| agent1.sinks.tube-sink-msg1.max-survived-time = 300000 |
| agent1.sinks.tube-sink-msg1.max-survived-size = 3000000 |
| agent1.sinks.tube-sink-msg1.new-check-pattern = true |
| agent1.sinks.tube-sink-msg1.old-metric-on=true |
| agent1.sinks.tube-sink-msg1.set=10 |
| |
| agent1.sinks.tube-sink-msg2.channel = ch-msg2 |
| agent1.sinks.tube-sink-msg2.type = org.apache.inlong.audit.sink.TubeSink |
| agent1.sinks.tube-sink-msg2.master-host-port-list = localhost:8715 |
| agent1.sinks.tube-sink-msg2.topic = inlong-audit |
| agent1.sinks.tube-sink-msg2.send_timeout = 30000 |
| agent1.sinks.tube-sink-msg2.stat-interval-sec = 60 |
| agent1.sinks.tube-sink-msg2.thread-num = 8 |
| agent1.sinks.tube-sink-msg2.client-id-cache = true |
| agent1.sinks.tube-sink-msg2.max-survived-time = 300000 |
| agent1.sinks.tube-sink-msg2.max-survived-size = 3000000 |
| agent1.sinks.tube-sink-msg2.new-check-pattern = true |
| agent1.sinks.tube-sink-msg2.old-metric-on=true |
| agent1.sinks.tube-sink-msg2.set=10 |
