galaxy-tsg-olap-storm-log-stream-completion/properties/service_flow_config.properties

#管理kafka地址
#bootstrap.servers=10.4.35.7:9092,10.4.35.8:9092,10.4.35.9:9092
bootstrap.servers=192.168.6.200:9093,192.168.6.200:9094,192.168.6.200:9095

#zookeeper 地址
zookeeper.servers=192.168.6.200:2181
#zookeeper.servers=192.168.40.207:2181

#latest/earliest
auto.offset.reset=latest

#kafka broker下的topic名称
kafka.topic=SESSION-RECORD-LOG
#kafka.topic=Snowflake-test

#读取topic,存储该spout id的消费offset信息，可通过该拓扑命名;具体存储offset的位置，确定下次读取不重复的数据；
group.id=session-record-log-z

#输出topic
#results.output.topic=SESSION-TEST-COMPLETED-LOG
results.output.topic=SESSION-RECORD-COMPLETED-LOG

#storm topology workers
topology.workers=1

#spout并行度 建议与kafka分区数相同
spout.parallelism=3

#处理补全操作的bolt并行度-worker的倍数
datacenter.bolt.parallelism=3

#写入kafkad的并行度
kafka.bolt.parallelism=3

#定位库地址
ip.library=/dat/

#kafka批量条数
batch.insert.num=5000

#数据中心（UID）
data.center.id.num=15

#tick时钟频率
topology.tick.tuple.freq.secs=5

#当bolt性能受限时，限制spout接收速度，理论看ack开启才有效
topology.config.max.spout.pending=150000

#ack设置 1启动ack 0不启动ack
topology.num.acks=0

#spout接收睡眠时间
topology.spout.sleep.time=1

#用于过滤对准用户名
check.ip.scope=10,100,192

#允许发送kafka最大失败数
max.failure.num=20

#influx地址
influx.ip=http://192.168.40.151:8086

#influx用户名
influx.username=admin

#influx密码
influx.password=admin