-
Notifications
You must be signed in to change notification settings - Fork 532
/
Copy pathaudit-proxy-tube.conf
90 lines (83 loc) · 3.99 KB
/
audit-proxy-tube.conf
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
#
# 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