109 lines
3.2 KiB
Plaintext
Executable File
109 lines
3.2 KiB
Plaintext
Executable File
metricSpoutThreads: 1
|
|
metricSpoutTasks: 1
|
|
|
|
# log location? node['mon_thresh']['log_dir']
|
|
|
|
metricSpoutConfig:
|
|
|
|
#Kafka settings.
|
|
kafkaConsumerConfiguration:
|
|
# See http://kafka.apache.org/documentation.html#api for semantics and defaults.
|
|
topic: <%= @settings['kafka']['metric']['topic'] %>
|
|
numThreads: 1
|
|
groupId: <%= @settings['kafka']['metric']['group'] %>
|
|
zookeeperConnect: <%= @settings['zookeeper']['host'] %>
|
|
consumerId: 1
|
|
socketTimeoutMs: 30000
|
|
socketReceiveBufferBytes : 65536
|
|
fetchMessageMaxBytes: 1048576
|
|
autoCommitEnable: true
|
|
autoCommitIntervalMs: 60000
|
|
queuedMaxMessageChunks: 10
|
|
rebalanceMaxRetries: 4
|
|
fetchMinBytes: 1
|
|
fetchWaitMaxMs: 100
|
|
rebalanceBackoffMs: 2000
|
|
refreshLeaderBackoffMs: 200
|
|
autoOffsetReset: largest
|
|
consumerTimeoutMs: -1
|
|
clientId : 1
|
|
zookeeperSessionTimeoutMs : 6000
|
|
zookeeperConnectionTimeoutMs : 6000
|
|
zookeeperSyncTimeMs: 2000
|
|
|
|
|
|
eventSpoutConfig:
|
|
#Kafka settings.
|
|
kafkaConsumerConfiguration:
|
|
# See http://kafka.apache.org/documentation.html#api for semantics and defaults.
|
|
topic: <%= @settings['kafka']['event']['consumer_topic'] %>
|
|
numThreads: 1
|
|
groupId: <%= @settings['kafka']['event']['group'] %>
|
|
zookeeperConnect: <%= @settings['zookeeper']['host'] %>
|
|
consumerId: 1
|
|
socketTimeoutMs: 30000
|
|
socketReceiveBufferBytes : 65536
|
|
fetchMessageMaxBytes: 1048576
|
|
autoCommitEnable: true
|
|
autoCommitIntervalMs: 60000
|
|
queuedMaxMessageChunks: 10
|
|
rebalanceMaxRetries: 4
|
|
fetchMinBytes: 1
|
|
fetchWaitMaxMs: 100
|
|
rebalanceBackoffMs: 2000
|
|
refreshLeaderBackoffMs: 200
|
|
autoOffsetReset: largest
|
|
consumerTimeoutMs: -1
|
|
clientId : 1
|
|
zookeeperSessionTimeoutMs : 6000
|
|
zookeeperConnectionTimeoutMs : 6000
|
|
zookeeperSyncTimeMs: 2000
|
|
|
|
|
|
kafkaProducerConfiguration:
|
|
# See http://kafka.apache.org/documentation.html#api for semantics and defaults.
|
|
topic: <%= @settings['kafka']['event']['producer_topic'] %>
|
|
metadataBrokerList: <%= @settings['kafka']['event']['host'] %>
|
|
serializerClass: kafka.serializer.StringEncoder
|
|
partitionerClass:
|
|
requestRequiredAcks: 1
|
|
requestTimeoutMs: 10000
|
|
producerType: sync
|
|
keySerializerClass:
|
|
compressionCodec: none
|
|
compressedTopics:
|
|
messageSendMaxRetries: 3
|
|
retryBackoffMs: 100
|
|
topicMetadataRefreshIntervalMs: 600000
|
|
queueBufferingMaxMs: 5000
|
|
queueBufferingMaxMessages: 10000
|
|
queueEnqueueTimeoutMs: -1
|
|
batchNumMessages: 200
|
|
sendBufferBytes: 102400
|
|
clientId : Threshold_Engine
|
|
|
|
|
|
sporadicMetricNamespaces:
|
|
- foo
|
|
|
|
database:
|
|
driverClass: com.mysql.jdbc.Driver
|
|
url: jdbc:mysql://<%= @settings['mysql']['host'] %>/<%= @settings['mysql']['db'] %>
|
|
user: <%= @credentials['mysql']['user'] %>
|
|
password: <%= @credentials['mysql']['password'] %>
|
|
properties:
|
|
ssl: false
|
|
# the maximum amount of time to wait on an empty pool before throwing an exception
|
|
maxWaitForConnection: 1s
|
|
|
|
# the SQL query to run when validating a connection's liveness
|
|
validationQuery: "/* MyService Health Check */ SELECT 1"
|
|
|
|
# the minimum number of connections to keep open
|
|
minSize: 8
|
|
|
|
# the maximum number of connections to keep open
|
|
|
|
|
|
maxSize: 41
|