diff --git a/inlong-dataproxy/conf/flume-mulit-pulsar-demo.conf b/inlong-dataproxy/conf/flume-mulit-pulsar-demo.conf index 851ba758bac..599b97a3ce1 100644 --- a/inlong-dataproxy/conf/flume-mulit-pulsar-demo.conf +++ b/inlong-dataproxy/conf/flume-mulit-pulsar-demo.conf @@ -25,7 +25,7 @@ agent1.sinks = pulsar-sink-msg1 pulsar-sink-msg2 pulsar-sink-msg5 pulsar-sink-ms agent1.sources.tcp-source.channels = ch-msg1 ch-msg2 ch-msg5 ch-msg6 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.host = 127.0.0.1 +agent1.sources.tcp-source.host = 0.0.0.0 agent1.sources.tcp-source.port = 46801 agent1.sources.tcp-source.max-msg-length = 524288 agent1.sources.tcp-source.topic = test1 @@ -73,7 +73,7 @@ agent1.channels.ch-msg6.fsyncInterval = 10 agent1.sinks.pulsar-sink-msg1.channel = ch-msg1 agent1.sinks.pulsar-sink-msg1.type = org.apache.inlong.dataproxy.sink.PulsarSink -agent1.sinks.pulsar-sink-msg1.pulsar_server_url_list = pulsar://127.0.0.1:6650,127.0.0.2:6650|pulsar://127.0.0.3:6650 +agent1.sinks.pulsar-sink-msg1.pulsar_server_url_list = pulsar://PULSAR_LIST agent1.sinks.pulsar-sink-msg1.send_timeout_MILL = 30000 agent1.sinks.pulsar-sink-msg1.stat_interval_sec = 60 agent1.sinks.pulsar-sink-msg1.thread-num = 8 @@ -85,7 +85,7 @@ agent1.sinks.pulsar-sink-msg1.disk-io-rate-per-sec=20000000 agent1.sinks.pulsar-sink-msg2.channel = ch-msg2 agent1.sinks.pulsar-sink-msg2.type = org.apache.inlong.dataproxy.sink.PulsarSink -agent1.sinks.pulsar-sink-msg2.pulsar_server_url_list = pulsar://127.0.0.1:6650,127.0.0.2:6650|pulsar://127.0.0.3:6650 +agent1.sinks.pulsar-sink-msg2.pulsar_server_url_list = pulsar://PULSAR_LIST agent1.sinks.pulsar-sink-msg2.send_timeout_MILL = 30000 agent1.sinks.pulsar-sink-msg2.stat_interval_sec = 60 agent1.sinks.pulsar-sink-msg2.thread-num = 8 @@ -97,7 +97,7 @@ agent1.sinks.pulsar-sink-msg2.disk-io-rate-per-sec=20000000 agent1.sinks.pulsar-sink-msg5.channel = ch-msg5 agent1.sinks.pulsar-sink-msg5.type = org.apache.inlong.dataproxy.sink.PulsarSink -agent1.sinks.pulsar-sink-msg5.pulsar_server_url_list = pulsar://127.0.0.1:6650,127.0.0.2:6650|pulsar://127.0.0.3:6650 +agent1.sinks.pulsar-sink-msg5.pulsar_server_url_list = pulsar://PULSAR_LIST agent1.sinks.pulsar-sink-msg5.send_timeout_MILL = 30000 agent1.sinks.pulsar-sink-msg5.stat_interval_sec = 60 agent1.sinks.pulsar-sink-msg5.thread-num = 8 @@ -108,8 +108,8 @@ agent1.sinks.pulsar-sink-msg5.netty_write_buffer_high_water_mark = 20971520 agent1.sinks.pulsar-sink-msg5.disk-io-rate-per-sec=20000000 agent1.sinks.pulsar-sink-msg6.channel = ch-msg6 -agent1.sinks.pulsar-sink-msg6.type = org.apache.inlong.dataproxy.PulsarSink -agent1.sinks.pulsar-sink-msg6.pulsar_server_url_list = pulsar://127.0.0.1:6650,127.0.0.2:6650|pulsar://127.0.0.3:6650 +agent1.sinks.pulsar-sink-msg6.type = org.apache.inlong.dataproxy.sink.PulsarSink +agent1.sinks.pulsar-sink-msg6.pulsar_server_url_list = pulsar://PULSAR_LIST agent1.sinks.pulsar-sink-msg6.send_timeout_MILL = 30000 agent1.sinks.pulsar-sink-msg6.stat_interval_sec = 60 agent1.sinks.pulsar-sink-msg6.thread-num = 8