Skip to content

Commit

Permalink
Merge to the master (#26)
Browse files Browse the repository at this point in the history
Merge to the master
  • Loading branch information
gnuhpc authored May 5, 2019
2 parents f6e9aa5 + d63f96c commit 8ddc88c
Show file tree
Hide file tree
Showing 114 changed files with 13,096 additions and 5,687 deletions.
6 changes: 3 additions & 3 deletions .travis.yml
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
language: java
jdk: oraclejdk8
install:
- mvn -N io.takari:maven:wrapper
- ./mvnw install -DskipTests=true -Dmaven.javadoc.skip=true -B -V
- mvn -N io.takari:maven:wrapper
- ./mvnw install -DskipTests=true -Dmaven.javadoc.skip=true -B -V
script:
- echo "skipping tests"
before_install:
- chmod +x mvnw
- chmod +x mvnw
364 changes: 182 additions & 182 deletions JMXFilterTemplate/KafkaBrokerFilter.yml
Original file line number Diff line number Diff line change
@@ -1,184 +1,184 @@
filters:
#
# Kafka volume metrics.
# Notice: BytesInPerSec, BytesOutPerSec and MessagesInPerSec are performance metrics.
#
- include:
domain: kafka.server
bean: kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_VOLUMN
alias: BytesIn
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: BytesInPerSec
- include:
domain: kafka.server
bean: kafka.server:type=BrokerTopicMetrics,name=BytesOutPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_VOLUMN
alias: BytesOut
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: BytesOutPerSec
- include:
domain: kafka.server
bean: kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_VOLUMN
alias: MessagesIn
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: MessagesInPerSec
#
# Kafka volume metrics.
# Notice: BytesInPerSec, BytesOutPerSec and MessagesInPerSec are performance metrics.
#
- include:
domain: kafka.server
bean: kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_VOLUMN
alias: BytesIn
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: BytesInPerSec
- include:
domain: kafka.server
bean: kafka.server:type=BrokerTopicMetrics,name=BytesOutPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_VOLUMN
alias: BytesOut
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: BytesOutPerSec
- include:
domain: kafka.server
bean: kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_VOLUMN
alias: MessagesIn
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: MessagesInPerSec

#
# Kafka performance metrics
#
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=RequestsPerSec,request=Produce
attribute:
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: RequestsPerSec_Produce
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=RequestsPerSec,request=FetchConsumer
attribute:
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: RequestsPerSec_FetchConsumer
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=RequestsPerSec,request=FetchFollower
attribute:
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: RequestsPerSec_FetchFollower
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=TotalTimeMs,request=Produce
attribute:
Mean:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_Produce_Mean
Count:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_Produce_Count
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=TotalTimeMs,request=FetchConsumer
attribute:
Mean:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_FetchConsumer_Mean
Count:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_FetchConsumer_Count
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=TotalTimeMs,request=FetchFollower
attribute:
Mean:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_FetchFollower_Mean
Count:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_FetchFollower_Count
- include:
domain: kafka.network
bean: kafka.network:type=SocketServer,name=NetworkProcessorAvgIdlePercent
attribute:
Value:
metric_type: KAFKA_BROKER_PERF
alias: NetworkProcessorAvgIdlePercent
- include:
domain: kafka.server
bean: kafka.server:type=KafkaRequestHandlerPool,name=RequestHandlerAvgIdlePercent
attribute:
FiveMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: RequestHandlerAvgIdlePercent
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaFetcherManager,name=MaxLag,clientId=Replica
attribute:
Value:
metric_type: KAFKA_BROKER_PERF
alias: MaxLagBtwFollowerLeader
#
# Kafka availability metrics
#
- include:
domain: java.lang
bean: java.lang:type=Runtime
attribute:
Uptime:
metric_type: KAFKA_BROKER_AVAIL
alias: JVMUptime
- include:
domain: kafka.controller
bean: kafka.controller:type=KafkaController,name=OfflinePartitionsCount
attribute:
Value:
metric_type: KAFKA_BROKER_AVAIL
alias: OfflinePartitionsCount
- include:
domain: kafka.controller
bean: kafka.controller:type=KafkaController,name=ActiveControllerCount
attribute:
Value:
metric_type: KAFKA_BROKER_AVAIL
alias: ActiveControllerCount
- include:
domain: kafka.controller
bean: kafka.controller:type=ControllerStats,name=LeaderElectionRateAndTimeMs
attribute:
Count:
metric_type: KAFKA_BROKER_AVAIL
alias: LeaderElectionRateAndTimeMs
- include:
domain: kafka.controller
bean: kafka.controller:type=ControllerStats,name=UncleanLeaderElectionsPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_AVAIL
alias: UncleanLeaderElectionsPerSec
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaManager,name=UnderReplicatedPartitions
attribute:
Value:
metric_type: KAFKA_BROKER_AVAIL
alias: UnderReplicatedPartitions
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaManager,name=PartitionCount
attribute:
Value:
metric_type: KAFKA_BROKER_AVAIL
alias: PartitionCount
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaManager,name=IsrShrinksPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_AVAIL
alias: IsrShrinksPerSec
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaManager,name=IsrExpandsPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_AVAIL
alias: IsrExpandsPerSec
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaManager,name=LeaderCount
attribute:
Value:
metric_type: KAFKA_BROKER_AVAIL
alias: LeaderCount
#
# Kafka performance metrics
#
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=RequestsPerSec,request=Produce
attribute:
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: RequestsPerSec_Produce
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=RequestsPerSec,request=FetchConsumer
attribute:
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: RequestsPerSec_FetchConsumer
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=RequestsPerSec,request=FetchFollower
attribute:
OneMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: RequestsPerSec_FetchFollower
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=TotalTimeMs,request=Produce
attribute:
Mean:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_Produce_Mean
Count:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_Produce_Count
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=TotalTimeMs,request=FetchConsumer
attribute:
Mean:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_FetchConsumer_Mean
Count:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_FetchConsumer_Count
- include:
domain: kafka.network
bean: kafka.network:type=RequestMetrics,name=TotalTimeMs,request=FetchFollower
attribute:
Mean:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_FetchFollower_Mean
Count:
metric_type: KAFKA_BROKER_PERF
alias: TotalTimeMs_FetchFollower_Count
- include:
domain: kafka.network
bean: kafka.network:type=SocketServer,name=NetworkProcessorAvgIdlePercent
attribute:
Value:
metric_type: KAFKA_BROKER_PERF
alias: NetworkProcessorAvgIdlePercent
- include:
domain: kafka.server
bean: kafka.server:type=KafkaRequestHandlerPool,name=RequestHandlerAvgIdlePercent
attribute:
FiveMinuteRate:
metric_type: KAFKA_BROKER_PERF
alias: RequestHandlerAvgIdlePercent
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaFetcherManager,name=MaxLag,clientId=Replica
attribute:
Value:
metric_type: KAFKA_BROKER_PERF
alias: MaxLagBtwFollowerLeader
#
# Kafka availability metrics
#
- include:
domain: java.lang
bean: java.lang:type=Runtime
attribute:
Uptime:
metric_type: KAFKA_BROKER_AVAIL
alias: JVMUptime
- include:
domain: kafka.controller
bean: kafka.controller:type=KafkaController,name=OfflinePartitionsCount
attribute:
Value:
metric_type: KAFKA_BROKER_AVAIL
alias: OfflinePartitionsCount
- include:
domain: kafka.controller
bean: kafka.controller:type=KafkaController,name=ActiveControllerCount
attribute:
Value:
metric_type: KAFKA_BROKER_AVAIL
alias: ActiveControllerCount
- include:
domain: kafka.controller
bean: kafka.controller:type=ControllerStats,name=LeaderElectionRateAndTimeMs
attribute:
Count:
metric_type: KAFKA_BROKER_AVAIL
alias: LeaderElectionRateAndTimeMs
- include:
domain: kafka.controller
bean: kafka.controller:type=ControllerStats,name=UncleanLeaderElectionsPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_AVAIL
alias: UncleanLeaderElectionsPerSec
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaManager,name=UnderReplicatedPartitions
attribute:
Value:
metric_type: KAFKA_BROKER_AVAIL
alias: UnderReplicatedPartitions
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaManager,name=PartitionCount
attribute:
Value:
metric_type: KAFKA_BROKER_AVAIL
alias: PartitionCount
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaManager,name=IsrShrinksPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_AVAIL
alias: IsrShrinksPerSec
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaManager,name=IsrExpandsPerSec
attribute:
Count:
metric_type: KAFKA_BROKER_AVAIL
alias: IsrExpandsPerSec
- include:
domain: kafka.server
bean: kafka.server:type=ReplicaManager,name=LeaderCount
attribute:
Value:
metric_type: KAFKA_BROKER_AVAIL
alias: LeaderCount
Loading

0 comments on commit 8ddc88c

Please sign in to comment.