blob: 3b4d25c2017b34830a27f7de5ecc87f378e6dfdd (
plain)
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
|
#管理kafka地址
bootstrap.servers={{ consumer_kafka_servers }}
#kafka broker下的topic名称
kafka.topic=RADIUS-RECORD-LOG
#kafka消费group id
group.id=radius-onff-log-20200818-1
#输出kafka server
results.output.servers={{ producer_kafka_servers }}
#输出topic
results.output.topic=RADIUS-ONFF-LOG
#从kafka哪里开始读：earliest/latest
auto.offset.reset=latest
#storm topology workers
topology.workers=1
#storm spout parallelism
spout.parallelism=3
#storm bolt parallelism
format.bolt.parallelism=3
#tick时钟频率
topology.tick.tuple.freq.secs=5
topology.config.max.spout.pending=500000
topology.num.acks=1
#kafka批量条数
batch.insert.num=500
|
