Catalogs of Metrics

The following statistics are collected by default from each Kafka broker connector, consumer, producer, ZooKeeper or stream. For more details on any specific metric, refer to the Apache Kafka documentation.

Apache Kafka Brokers

Influx Measurement Mbean Object Attributes (Influx fields) Influx Tags
KafkaClusterPartitionAtMinIsr kafka.cluster:type=Partition,name=AtMinIsr,topic=*,partition=* Value type, name, topic, partition
KafkaClusterPartitionInSyncReplicasCount kafka.cluster:type=Partition,name=InSyncReplicasCount,topic=*,partition=* Value type, name, topic, partition
KafkaClusterPartitionLastStableOffsetLag kafka.cluster:type=Partition,name=LastStableOffsetLag,topic=*,partition=* Value type, name, topic, partition
KafkaClusterPartitionReplicasCount kafka.cluster:type=Partition,name=ReplicasCount,topic=*,partition=* Value type, name, topic, partition
KafkaClusterPartitionUnderMinIsr kafka.cluster:type=Partition,name=UnderMinIsr,topic=*,partition=* Value type, name, topic, partition
KafkaClusterPartitionUnderReplicated kafka.cluster:type=Partition,name=UnderReplicated,topic=*,partition=* Value type, name, topic, partition
KafkaControllerControllerChannelManagerTotalQueueSize kafka.controller:type=ControllerChannelManager,name=TotalQueueSize Value type, name
KafkaControllerControllerEventManagerEventQueueSize kafka.controller:type=ControllerEventManager,name=EventQueueSize Value type, name
KafkaControllerControllerEventManagerEventQueueTimeMs kafka.controller:type=ControllerEventManager,name=EventQueueTimeMs Count, Max, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name
KafkaControllerControllerStatsAutoLeaderBalanceRateAndTimeMs kafka.controller:type=ControllerStats,name=AutoLeaderBalanceRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsControlledShutdownRateAndTimeMs kafka.controller:type=ControllerStats,name=ControlledShutdownRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsControllerChangeRateAndTimeMs kafka.controller:type=ControllerStats,name=ControllerChangeRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsControllerShutdownRateAndTimeMs kafka.controller:type=ControllerStats,name=ControllerShutdownRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsIsrChangeRateAndTimeMs kafka.controller:type=ControllerStats,name=IsrChangeRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsLeaderAndIsrResponseReceivedRateAndTimeMs kafka.controller:type=ControllerStats,name=LeaderAndIsrResponseReceivedRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsLeaderElectionRateAndTimeMs kafka.controller:type=ControllerStats,name=LeaderElectionRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsListPartitionReassignmentRateAndTimeMs kafka.controller:type=ControllerStats,name=ListPartitionReassignmentRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsLogDirChangeRateAndTimeMs kafka.controller:type=ControllerStats,name=LogDirChangeRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsManualLeaderBalanceRateAndTimeMs kafka.controller:type=ControllerStats,name=ManualLeaderBalanceRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsPartitionReassignmentRateAndTimeMs kafka.controller:type=ControllerStats,name=PartitionReassignmentRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsTopicChangeRateAndTimeMs kafka.controller:type=ControllerStats,name=TopicChangeRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsTopicDeletionRateAndTimeMs kafka.controller:type=ControllerStats,name=TopicDeletionRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsTopicUncleanLeaderElectionEnableRateAndTimeMs kafka.controller:type=ControllerStats,name=TopicUncleanLeaderElectionEnableRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsUncleanLeaderElectionEnableRateAndTimeMs kafka.controller:type=ControllerStats,name=UncleanLeaderElectionEnableRateAndTimeMs Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate, 50thPercentile, Min, Mean, StdDev, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile, Max type, name
KafkaControllerControllerStatsUncleanLeaderElectionsPerSec kafka.controller:type=ControllerStats,name=UncleanLeaderElectionsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaControllerKafkaControllerActiveControllerCount kafka.controller:type=KafkaController,name=ActiveControllerCount Value type, name
KafkaControllerKafkaControllerControllerState kafka.controller:type=KafkaController,name=ControllerState Value type, name
KafkaControllerKafkaControllerGlobalPartitionCount kafka.controller:type=KafkaController,name=GlobalPartitionCount Value type, name
KafkaControllerKafkaControllerGlobalTopicCount kafka.controller:type=KafkaController,name=GlobalTopicCount Value type, name
KafkaControllerKafkaControllerOfflinePartitionsCount kafka.controller:type=KafkaController,name=OfflinePartitionsCount Value type, name
KafkaControllerKafkaControllerPreferredReplicaImbalanceCount kafka.controller:type=KafkaController,name=PreferredReplicaImbalanceCount Value type, name
KafkaControllerKafkaControllerReplicasIneligibleToDeleteCount kafka.controller:type=KafkaController,name=ReplicasIneligibleToDeleteCount Value type, name
KafkaControllerKafkaControllerReplicasToDeleteCount kafka.controller:type=KafkaController,name=ReplicasToDeleteCount Value type, name
KafkaControllerKafkaControllerTopicsIneligibleToDeleteCount kafka.controller:type=KafkaController,name=TopicsIneligibleToDeleteCount Value type, name
KafkaControllerKafkaControllerTopicsToDeleteCount kafka.controller:type=KafkaController,name=TopicsToDeleteCount Value type, name
KafkaCoordinatorGroupGroupMetadataManagerNumGroups kafka.coordinator.group:type=GroupMetadataManager,name=NumGroups Value type, name
KafkaCoordinatorGroupGroupMetadataManagerNumGroupsCompletingRebalance kafka.coordinator.group:type=GroupMetadataManager,name=NumGroupsCompletingRebalance Value type, name
KafkaCoordinatorGroupGroupMetadataManagerNumGroupsDead kafka.coordinator.group:type=GroupMetadataManager,name=NumGroupsDead Value type, name
KafkaCoordinatorGroupGroupMetadataManagerNumGroupsEmpty kafka.coordinator.group:type=GroupMetadataManager,name=NumGroupsEmpty Value type, name
KafkaCoordinatorGroupGroupMetadataManagerNumGroupsPreparingRebalance kafka.coordinator.group:type=GroupMetadataManager,name=NumGroupsPreparingRebalance Value type, name
KafkaCoordinatorGroupGroupMetadataManagerNumGroupsStable kafka.coordinator.group:type=GroupMetadataManager,name=NumGroupsStable Value type, name
KafkaCoordinatorGroupGroupMetadataManagerNumOffsets kafka.coordinator.group:type=GroupMetadataManager,name=NumOffsets Value type, name
KafkaCoordinatorTransactionTransactionMarkerChannelManagerLogAppendRetryQueueSize kafka.coordinator.transaction:type=TransactionMarkerChannelManager,name=LogAppendRetryQueueSize Value type, name
KafkaCoordinatorTransactionTransactionMarkerChannelManagerUnknownDestinationQueueSize kafka.coordinator.transaction:type=TransactionMarkerChannelManager,name=UnknownDestinationQueueSize Value type, name
KafkaLogLogLogEndOffset kafka.log:type=Log,name=LogEndOffset,topic=*,partition=* Value type, name, topic, partition
KafkaLogLogLogStartOffset kafka.log:type=Log,name=LogStartOffset,topic=*,partition=* Value type, name, topic, partition
KafkaLogLogNumLogSegments kafka.log:type=Log,name=NumLogSegments,topic=*,partition=* Value type, name, topic, partition
KafkaLogLogSize kafka.log:type=Log,name=Size,topic=*,partition=* Value type, name, topic, partition
KafkaLogLogCleanerDeadThreadCount kafka.log:type=LogCleaner,name=DeadThreadCount Value type, name
KafkaLogLogCleanerCleanerRecopyPercent kafka.log:type=LogCleaner,name=cleaner-recopy-percent Value type, name
KafkaLogLogCleanerCleanerMaxBufferUtilizationPercent kafka.log:type=LogCleaner,name=max-buffer-utilization-percent Value type, name
KafkaLogLogCleanerCleanerMaxCleanTimeSecs kafka.log:type=LogCleaner,name=max-clean-time-secs Value type, name
KafkaLogLogCleanerCleanerMaxCompactionDelaySecs kafka.log:type=LogCleaner,name=max-compaction-delay-secs Value type, name
KafkaLogLogCleanerManagerMaxDirtyPercent kafka.log:type=LogCleanerManager,name=max-dirty-percent Value type, name
KafkaLogLogCleanerManagerTimeSinceLastRunMs kafka.log:type=LogCleanerManager,name=time-since-last-run-ms Value type, name
KafkaLogLogCleanerManagerUncleanableBytes kafka.log:type=LogCleanerManager,name=uncleanable-bytes,logDirectory=* Value type, name, logDirectory
KafkaLogLogCleanerManagerUncleanablePartitionsCount kafka.log:type=LogCleanerManager,name=uncleanable-partitions-count,logDirectory=* Value type, name, logDirectory
KafkaLogLogManagerLogDirectoryOffline kafka.log:type=LogManager,name=LogDirectoryOffline,logDirectory=* Value type, name, logDirectory
KafkaLogLogManagerOfflineLogDirectoryCount kafka.log:type=LogManager,name=OfflineLogDirectoryCount Value type, name
KafkaNetworkAcceptorAcceptorBlockedPercent kafka.network:type=Acceptor,name=AcceptorBlockedPercent,listener=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, listener
KafkaNetworkProcessorIdlePercent kafka.network:type=Processor,name=IdlePercent,networkProcessor=* Value type, name, networkProcessor
KafkaNetworkRequestChannelRequestQueueSize kafka.network:type=RequestChannelRequestQueueSize Value type
KafkaNetworkRequestChannelResponseQueueSize kafka.network:type=RequestChannel,name=ResponseQueueSize Value type, name
KafkaNetworkRequestChannelResponseQueueSizeProcessor kafka.network:type=RequestChannel,name=ResponseQueueSize,processor=* Value type, name, processor
KafkaNetworkRequestMetricsErrorsPerSec kafka.network:type=RequestMetrics,name=ErrorsPerSec,request=*,error=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, request, error
KafkaNetworkRequestMetricsLocalTimeMs kafka.network:type=RequestMetrics,name=LocalTimeMs,request=* Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name, request
KafkaNetworkRequestMetricsMessageConversionsTimeMs kafka.network:type=RequestMetrics,name=MessageConversionsTimeMs,request=* Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name, request
KafkaNetworkRequestMetricsRemoteTimeMs kafka.network:type=RequestMetrics,name=RemoteTimeMs,request=* Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name, request
KafkaNetworkRequestMetricsRequestBytes kafka.network:type=RequestMetrics,name=RequestBytes,request=* Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name, request
KafkaNetworkRequestMetricsRequestQueueTimeMs kafka.network:type=RequestMetrics,name=RequestQueueTimeMs,request=* Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name, request
KafkaNetworkRequestMetricsRequestsPerSec kafka.network:type=RequestMetrics,name=RequestsPerSec,request=*,version=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, request, version
KafkaNetworkRequestMetricsResponseQueueTimeMs kafka.network:type=RequestMetrics,name=ResponseQueueTimeMs,request=* Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name, request
KafkaNetworkRequestMetricsResponseSendTimeMs kafka.network:type=RequestMetrics,name=ResponseSendTimeMs,request=* Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name, request
KafkaNetworkRequestMetricsTemporaryMemoryBytes kafka.network:type=RequestMetrics,name=TemporaryMemoryBytes,request=* Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name, request
KafkaNetworkRequestMetricsThrottleTimeMs kafka.network:type=RequestMetrics,name=ThrottleTimeMs,request=* Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name, request
KafkaNetworkRequestMetricsTotalTimeMs kafka.network:type=RequestMetrics,name=TotalTimeMs,request=* Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name, request
KafkaNetworkSocketServerControlPlaneExpiredConnectionsKilledCount kafka.network:type=SocketServer,name=ControlPlaneExpiredConnectionsKilledCount Value type, name
KafkaNetworkSocketServerControlPlaneNetworkProcessorAvgIdlePercent kafka.network:type=SocketServer,name=ControlPlaneNetworkProcessorAvgIdlePercent Value type, name
KafkaNetworkSocketServerExpiredConnectionsKilledCount kafka.network:type=SocketServer,name=ExpiredConnectionsKilledCount Value type, name
KafkaNetworkSocketServerMemoryPoolAvailable kafka.network:type=SocketServer,name=MemoryPoolAvailable Value type, name
KafkaNetworkSocketServerMemoryPoolUsed kafka.network:type=SocketServer,name=MemoryPoolUsed Value type, name
KafkaNetworkSocketServerNetworkProcessorAvgIdlePercent kafka.network:type=SocketServer,name=NetworkProcessorAvgIdlePercent Value type, name
KafkaServerBrokerTopicMetricsBytesInPerSec kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsBytesInPerSecTopic kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsBytesOutPerSec kafka.server:type=BrokerTopicMetrics,name=BytesOutPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsBytesOutPerSecTopic kafka.server:type=BrokerTopicMetrics,name=BytesOutPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsBytesRejectedPerSec kafka.server:type=BrokerTopicMetrics,name=BytesRejectedPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsBytesRejectedPerSecTopic kafka.server:type=BrokerTopicMetrics,name=BytesRejectedPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsFailedFetchRequestsPerSec kafka.server:type=BrokerTopicMetrics,name=FailedFetchRequestsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsFailedFetchRequestsPerSecTopic kafka.server:type=BrokerTopicMetrics,name=FailedFetchRequestsPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsFailedProduceRequestsPerSec kafka.server:type=BrokerTopicMetrics,name=FailedProduceRequestsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsFailedProduceRequestsPerSecTopic kafka.server:type=BrokerTopicMetrics,name=FailedProduceRequestsPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsFetchMessageConversionsPerSec kafka.server:type=BrokerTopicMetrics,name=FetchMessageConversionsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsFetchMessageConversionsPerSecTopic kafka.server:type=BrokerTopicMetrics,name=FetchMessageConversionsPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsInvalidMagicNumberRecordsPerSec kafka.server:type=BrokerTopicMetrics,name=InvalidMagicNumberRecordsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsInvalidMagicNumberRecordsPerSecTopic kafka.server:type=BrokerTopicMetrics,name=InvalidMagicNumberRecordsPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsInvalidMessageCrcRecordsPerSec kafka.server:type=BrokerTopicMetrics,name=InvalidMessageCrcRecordsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsInvalidMessageCrcRecordsPerSecTopic kafka.server:type=BrokerTopicMetrics,name=InvalidMessageCrcRecordsPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsInvalidOffsetOrSequenceRecordsPerSec kafka.server:type=BrokerTopicMetrics,name=InvalidOffsetOrSequenceRecordsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsInvalidOffsetOrSequenceRecordsPerSecTopic kafka.server:type=BrokerTopicMetrics,name=InvalidOffsetOrSequenceRecordsPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsMessagesInPerSec kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsMessagesInPerSecTopic kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsNoKeyCompactedTopicRecordsPerSec kafka.server:type=BrokerTopicMetrics,name=NoKeyCompactedTopicRecordsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsNoKeyCompactedTopicRecordsPerSecTopic kafka.server:type=BrokerTopicMetrics,name=NoKeyCompactedTopicRecordsPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsProduceMessageConversionsPerSec kafka.server:type=BrokerTopicMetrics,name=ProduceMessageConversionsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsProduceMessageConversionsPerSecTopic kafka.server:type=BrokerTopicMetrics,name=ProduceMessageConversionsPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsReassignmentBytesInPerSec kafka.server:type=BrokerTopicMetrics,name=ReassignmentBytesInPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsReassignmentBytesInPerSecTopic kafka.server:type=BrokerTopicMetrics,name=ReassignmentBytesInPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsReassignmentBytesOutPerSec kafka.server:type=BrokerTopicMetrics,name=ReassignmentBytesOutPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsReassignmentBytesOutPerSecTopic kafka.server:type=BrokerTopicMetrics,name=ReassignmentBytesOutPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsReplicationBytesInPerSec kafka.server:type=BrokerTopicMetrics,name=ReplicationBytesInPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsReplicationBytesInPerSecTopic kafka.server:type=BrokerTopicMetrics,name=ReplicationBytesInPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsReplicationBytesOutPerSec kafka.server:type=BrokerTopicMetrics,name=ReplicationBytesOutPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsReplicationBytesOutPerSecTopic kafka.server:type=BrokerTopicMetrics,name=ReplicationBytesOutPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsTotalFetchRequestsPerSec kafka.server:type=BrokerTopicMetrics,name=TotalFetchRequestsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsTotalFetchRequestsPerSecTopic kafka.server:type=BrokerTopicMetrics,name=TotalFetchRequestsPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerBrokerTopicMetricsTotalProduceRequestsPerSec kafka.server:type=BrokerTopicMetrics,name=TotalProduceRequestsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerBrokerTopicMetricsTotalProduceRequestsPerSecTopic kafka.server:type=BrokerTopicMetrics,name=TotalProduceRequestsPerSec,topic=* Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name, topic
KafkaServerDelayedOperationPurgatoryNumDelayedOperations kafka.server:type=DelayedOperationPurgatory,name=NumDelayedOperations,delayedOperation=* Value type, name, delayedOperation
KafkaServerDelayedOperationPurgatoryPurgatorySize kafka.server:type=DelayedOperationPurgatory,name=PurgatorySize,delayedOperation=* Value type, name, delayedOperation
KafkaServerFetch kafka.server:type=Fetch queue-size type
KafkaServerFetchSessionCacheIncrementalFetchSessionEvictionsPerSec kafka.server:type=FetchSessionCache,name=IncrementalFetchSessionEvictionsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerFetchSessionCacheNumIncrementalFetchPartitionsCached kafka.server:type=FetchSessionCache,name=NumIncrementalFetchPartitionsCached Value type, name
KafkaServerFetchSessionCacheNumIncrementalFetchSessions kafka.server:type=FetchSessionCache,name=NumIncrementalFetchSessions Value type, name
KafkaServerKafkaRequestHandlerPoolRequestHandlerAvgIdlePercent kafka.server:type=KafkaRequestHandlerPool,name=RequestHandlerAvgIdlePercent Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkServerKafkaServerBrokerState kafka.server:type=KafkaServer,name=BrokerState Value type, name
KafkServerKafkaServerClusterId kafka.server:type=KafkaServer,name=ClusterId Value type, name
KafkServerKafkaServerYammerMetricsCount kafka.server:type=KafkaServer,name=yammer-metrics-count Value type, name
KafkaServerProduce kafka.server:type=Produce queue-size type
KafkaServerReplicaAlterLogDirsManagerDeadThreadCount kafka.server:type=ReplicaAlterLogDirsManager,name=DeadThreadCount,clientId=* Value type, name, clientId
KafkaServerReplicaAlterLogDirsManagerFailedPartitionCount kafka.server:type=ReplicaAlterLogDirsManager,name=FailedPartitionCount,clientId=* Value type, name, clientId
KafkaServerReplicaAlterLogDirsManagerMaxLag kafka.server:type=ReplicaAlterLogDirsManager,name=MaxLag,clientId=* Value type, name, clientId
KafkaServerReplicaAlterLogDirsManagerMinFetchRate kafka.server:type=ReplicaAlterLogDirsManager,name=MinFetchRate,clientId=* Value type, name, clientId
KafkaServerReplicaFetcherManagerDeadThreadCount kafka.server:type=ReplicaFetcherManager,name=DeadThreadCount,clientId=* Value type, name, clientId
KafkaServerReplicaFetcherManagerFailedPartitionsCount kafka.server:type=ReplicaFetcherManager,name=FailedPartitionsCount,clientId=* Value type, name, clientId
KafkaServerReplicaFetcherManagerMaxLag kafka.server:type=ReplicaFetcherManager,name=MaxLag,clientId=* Value type, name, clientId
KafkaServerReplicaFetcherManagerMinFetchRate kafka.server:type=ReplicaFetcherManager,name=MinFetchRate,clientId=* Value type, name, clientId
KafkaServerReplicaManagerAtMinIsrPartitionCount kafka.server:type=ReplicaManager,name=AtMinIsrPartitionCount Value type, name
KafkaServerReplicaManagerFailedIsrUpdatesPerSec kafka.server:type=ReplicaManager,name=FailedIsrUpdatesPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerReplicaManagerIsrExpandsPerSec kafka.server:type=ReplicaManager,name=IsrExpandsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerReplicaManagerIsrShrinksPerSec kafka.server:type=ReplicaManager,name=IsrShrinksPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerReplicaManagerLeaderCount kafka.server:type=ReplicaManager,name=LeaderCount Value type, name
KafkaServerReplicaManagerOfflineReplicaCount kafka.server:type=ReplicaManager,name=OfflineReplicaCount Value type, name
KafkaServerReplicaManagerPartitionCount kafka.server:type=ReplicaManager,name=PartitionCount Value type, name
KafkaServerReplicaManagerReassigningPartitions kafka.server:type=ReplicaManager,name=ReassigningPartitions Value type, name
KafkaServerReplicaManagerUnderMinIsrPartitionCount kafka.server:type=ReplicaManager,name=UnderMinIsrPartitionCount Value type, name
KafkaServerReplicaManagerUnderReplicatedPartitions kafka.server:type=ReplicaManager,name=UnderReplicatedPartitions Value type, name
KafkaServerRequest kafka.server:type=Request queue-size type
KafkaServerSessionExpireListenerSessionState kafka.server:type=SessionExpireListener,name=SessionState Value type, name
KafkaServerSessionExpireListenerZooKeeperAuthFailuresPerSec kafka.server:type=SessionExpireListener,name=ZooKeeperAuthFailuresPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerSessionExpireListenerZooKeeperDisconnectsPerSec kafka.server:type=SessionExpireListener,name=ZooKeeperDisconnectsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerSessionExpireListenerZooKeeperExpiresPerSec kafka.server:type=SessionExpireListener,name=ZooKeeperExpiresPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerSessionExpireListenerZooKeeperReadOnlyConnectsPerSec kafka.server:type=SessionExpireListener,name=ZooKeeperReadOnlyConnectsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerSessionExpireListenerZooKeeperSaslAuthenticationsPerSec kafka.server:type=SessionExpireListener,name=ZooKeeperSaslAuthenticationsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerSessionExpireListenerZooKeeperSyncConnectsPerSec kafka.server:type=SessionExpireListener,name=ZooKeeperSyncConnectsPerSec Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
KafkaServerZooKeeperClientMetricsZooKeeperRequestLatencyMs kafka.server:type=ZooKeeperClientMetrics,name=ZooKeeperRequestLatencyMs Count, Min, Max, Mean, StdDev, 50thPercentile, 75thPercentile, 95thPercentile, 98thPercentile, 99thPercentile, 999thPercentile type, name
KafkaServerAppInfo kafka.server:type=app-info commit-id, start-time-ms, version type
KafkaServerAppInfoId kafka.server:type=app-info,id=* Version, CommitId, StartTimeMs type, id
KafkaServerGroupCoordinatorMetrics kafka.server:type=group-coordinator-metrics group-completed-rebalance-count, group-completed-rebalance-rate, offset-commit-count, offset-commit-rate, offset-deletion-count, offset-deletion-rate, offset-expiration-count, offset-expiration-rate, partition-load-time-avg, partition-load-time-max type
KafkaServerKafkaMetricsCount kafka.server:type=kafka-metrics-count count type
KafkaServerSocketServerMetrics kafka.server:type=socket-server-metrics MemoryPoolDepletedTimeTotal, MemoryPoolAvgDepletedPercent type
KafkaServerSocketServerMetricsListener kafka.server:type=socket-server-metrics,listener=*,networkProcessor=* connection-close-rate, connection-close-total, connection-count, connection-creation-rate, connection-creation-total, expired-connections-killed-count, failed-authentication-rate, failed-authentication-total, failed-reauthentication-rate, failed-reauthentication-total, incoming-byte-rate, incoming-byte-total, io-ratio, io-time-ns-avg, io-wait-ratio, io-wait-time-ns-avg, io-waittime-total, iotime-total, network-io-rate, network-io-total, outgoing-byte-rate, outgoing-byte-total, reauthentication-latency-avg, reauthentication-latency-max, request-rate, request-size-avg, request-size-max, request-total, response-rate, response-total, select-rate, select-total, successful-authentication-no-reauth-total, successful-authentication-rate, successful-authentication-total, successful-reauthentication-rate, successful-reauthentication-total type, networkProcessor, listener
KafkaServerTransactionCoordinatorMetrics kafka.server:type=transaction-coordinator-metrics partition-load-time-avg, partition-load-time-max type
KafkaServerTxnMarkerChannelMetrics kafka.server:type=txn-marker-channel-metrics connection-close-rate, connection-close-total, connection-count, connection-creation-rate, connection-creation-total, failed-authentication-rate, failed-authentication-total, failed-reauthentication-rate, failed-reauthentication-total, incoming-byte-rate, incoming-byte-total, io-ratio, io-time-ns-avg, io-wait-ratio, io-wait-time-ns-avg, io-waittime-total, iotime-total, network-io-rate, network-io-total, outgoing-byte-rate, outgoing-byte-total, reauthentication-latency-avg, reauthentication-latency-max, request-rate, request-size-avg, request-size-max, request-total, response-rate, response-total, select-rate, select-total, successful-authentication-no-reauth-total, successful-authentication-rate, successful-authentication-total, successful-reauthentication-rate, successful-reauthentication-total type
KafkaUtilsThrottlerCleanerIO kafka.utils:type=Throttler,name=cleaner-io Count, MeanRate, OneMinuteRate, FiveMinuteRate, FifteenMinuteRate type, name
JavaLangOperatingSystem java.lang:type=OperatingSystem OpenFileDescriptorCount, MaxFileDescriptorCount, CommittedVirtualMemorySize, TotalSwapSpaceSize, FreeSwapSpaceSize, ProcessCpuTime, FreePhysicalMemorySize, TotalPhysicalMemorySize, SystemCpuLoad, ProcessCpuLoad, Arch, Version, SystemLoadAverage, AvailableProcessors, Name, ObjectName type
JavaLangMemory java.lang:type=Memory HeapMemoryUsage, NonHeapMemoryUsage type
JavaLangMemoryPool java.lang:type=MemoryPool,name=* PeakUsage, UsageThreshold, UsageThresholdExceeded, UsageThresholdCount, UsageThresholdSupported, CollectionUsageThreshold, CollectionUsageThresholdExceeded, CollectionUsageThresholdCount, CollectionUsage, CollectionUsageThresholdSupported type, name
JavaLangThreading java.lang:type=Threading CurrentThreadCpuTime, CurrentThreadUserTime, DaemonThreadCount, PeakThreadCount, ThreadCount, TotalStartedThreadCount type
JavaLangRuntime java.lang:type=Runtime Uptime type
JavaLangGarbageCollector java.lang:type=GarbageCollector,name=* CollectionCount, CollectionTime, LastGcInfo, MemoryPoolNames type, name
JavaNioBufferPool java.nio:type=BufferPool,name=* Count, MemoryUsed, TotalCapacity type, name

Apache Kafka Connectors

Influx Measurement Mbean Object Attributes (Influx fields) Influx Tags
KafkaConnectAppInfoClientId kafka.connect:type=app-info commit-id, start-time-ms, version type
KafkaConnectAppInfoId kafka.connect:type=app-info,id=* Version, CommitId, StartTimeMs type, id
KafkaConnectConnectMetrics kafka.connect:type=connect-metrics,client-id=* connection-close-rate, connection-close-total, connection-creation-rate, connection-creation-total, network-io-rate, network-io-total, outgoing-byte-rate, outgoing-byte-total, request-rate, request-total, request-size-avg, request-size-max, incoming-byte-rate, incoming-byte-total, response-rate, response-total, select-rate, select-total, io-wait-time-ns-avg, io-wait-ratio, io-time-ns-avg, io-ratio, connection-count, successful-authentication-rate, successful-authentication-total, failed-authentication-rate, failed-authentication-total, successful-reauthentication-rate, successful-reauthentication-total, reauthentication-latency-max, reauthentication-latency-avg, failed-reauthentication-rate, failed-reauthentication-total, successful-authentication-no-reauth-total type, client-id
KafkaConnectConnectWorkerMetrics kafka.connect:type=connect-worker-metrics connector-count, connector-startup-attempts-total, connector-startup-failure-percentage, connector-startup-failure-total, connector-startup-success-percentage, connector-startup-success-total, task-count, task-startup-attempts-total, task-startup-failure-percentage, task-startup-failure-total, task-startup-success-percentage, task-startup-success-total type
KafkaConnectConnectWorkerConnectorMetrics kafka.connect:type=connect-worker-metrics,connector=* connector-destroyed-task-count, connector-failed-task-count, connector-paused-task-count, connector-running-task-count, connector-total-task-count, connector-unassigned-task-count type, connector
KafkaConnectConnectWorkerRebalaceMetrics kafka.connect:type=connect-worker-rebalance-metrics completed-rebalances-total, connect-protocol, epoch, leader-name, rebalance-avg-time-ms, rebalance-max-time-ms, rebalancing, time-since-last-rebalance-ms type
KafkaConnectConnectNodeMetrics kafka.connect:type=connect-node-metrics,client-id=*,node-id=* outgoing-byte-rate, outgoing-byte-total, request-rate, request-total, request-size-avg, request-size-max, incoming-byte-rate, incoming-byte-total, request-latency-avg, request-latency-max, response-rate, response-total type, client-id, node-id
KafkaConnectConnectorMetrics kafka.connect:type=connector-metrics,connector=* connector-class, connector-type, connector-version, status type, connector
KafkaConnectConnectorTaskMetrics kafka.connect:type=connector-task-metrics,connector=*,task=* batch-size-avg, batch-size-max, offset-commit-avg-time-ms, offset-commit-failure-percentage, offset-commit-max-time-ms, offset-commit-success-percentage, pause-ratio, running-ratio, status type, connector, task
KafkaConnectKafkaMetricsCount kafka.connect:type=kafka-metrics-count count type
KafkaConnectSinkTaskMetrics kafka.connect:type=sink-task-metrics,connector=*,task=* offset-commit-completion-rate, offset-commit-completion-total, offset-commit-seq-no, offset-commit-skip-rate, offset-commit-skip-total, partition-count, put-batch-avg-time-ms, put-batch-max-time-ms, sink-record-active-count, sink-record-active-count-avg, sink-record-active-count-max, sink-record-read-rate, sink-record-read-total, sink-record-send-rate, sink-record-send-total type, connector, task
KafkaConnectSourceTaskMetrics kafka.connect:type=source-task-metrics,connector=*,task=* poll-batch-avg-time-ms, poll-batch-max-time-ms, source-record-active-count, source-record-active-count-avg, source-record-active-count-max, source-record-poll-rate, source-record-poll-total, source-record-write-rate, source-record-write-total type, connector, task
KafkaConnectTaskErrorMetrics kafka.connect:type=task-error-metrics,connector=*,task=* deadletterqueue-produce-failures, deadletterqueue-produce-requests, last-error-timestamp, total-errors-logged, total-record-errors, total-record-failures, total-records-skipped, total-retries type, connector, task
JavaLangOperatingSystem java.lang:type=OperatingSystem OpenFileDescriptorCount, MaxFileDescriptorCount, CommittedVirtualMemorySize, TotalSwapSpaceSize, FreeSwapSpaceSize, ProcessCpuTime, FreePhysicalMemorySize, TotalPhysicalMemorySize, SystemCpuLoad, ProcessCpuLoad, Arch, Version, SystemLoadAverage, AvailableProcessors, Name, ObjectName type
JavaLangMemory java.lang:type=Memory HeapMemoryUsage, NonHeapMemoryUsage type
JavaLangMemoryPool java.lang:type=MemoryPool,name=* PeakUsage, UsageThreshold, UsageThresholdExceeded, UsageThresholdCount, UsageThresholdSupported, CollectionUsageThreshold, CollectionUsageThresholdExceeded, CollectionUsageThresholdCount, CollectionUsage, CollectionUsageThresholdSupported type, name
JavaLangThreading java.lang:type=Threading CurrentThreadCpuTime, CurrentThreadUserTime, DaemonThreadCount, PeakThreadCount, ThreadCount, TotalStartedThreadCount type
JavaLangRuntime java.lang:type=Runtime Uptime type
JavaLangGarbageCollector java.lang:type=GarbageCollector,name=* CollectionCount, CollectionTime, LastGcInfo, MemoryPoolNames type, name
JavaNioBufferPool java.nio:type=BufferPool,name=* Count, MemoryUsed, TotalCapacity type, name

Apache Kafka Consumer

Influx Measurement Mbean Object Attributes (Influx fields) Influx Tags
KafkaConsumerAppInfoClientId kafka.consumer:type=app-info,client-id=* commit-id, start-time-ms, version type, client-id
KafkaConsumerAppInfoId kafka.consumer:type=app-info,id=* Version, CommitId, StartTimeMs type, id
KafkaConsumerConsumerCoordinatorMetrics kafka.consumer:type=consumer-coordinator-metrics,client-id=* assigned-partitions, commit-latency-avg, commit-latency-max, commit-rate, commit-total, failed-rebalance-rate-per-hour, failed-rebalance-total, heartbeat-rate, heartbeat-response-time-max, heartbeat-total, join-rate, join-time-avg, join-time-max, join-total, last-heartbeat-seconds-ago, last-heartbeat-seconds-ago, last-rebalance-seconds-ago, partition-assigned-latency-avg, partition-assigned-latency-max, partition-lost-latency-avg, partition-lost-latency-max, partition-revoked-latency-avg, partition-revoked-latency-max, rebalance-latency-avg, rebalance-latency-max, rebalance-latency-total, rebalance-rate-per-hour, rebalance-total, sync-rate, sync-time-avg, sync-time-max, sync-total type, client-id
KafkaConsumerConsumerFetchManagerMetrics kafka.consumer:type=consumer-fetch-manager-metrics,client-id=* bytes-consumed-rate, bytes-consumed-total, fetch-latency-avg, fetch-latency-max, fetch-rate, fetch-size-avg, fetch-size-max, fetch-throttle-time-avg, fetch-throttle-time-max, fetch-total, records-consumed-rate, records-consumed-total, records-lag-max, records-lead-min, records-per-request-avg type, client-id
KafkaConsumerConsumerFetchManagerMetricsTopic kafka.consumer:type=consumer-fetch-manager-metrics,client-id=*,topic=* bytes-consumed-rate, bytes-consumed-total, fetch-size-avg, fetch-size-max, records-consumed-rate, records-consumed-total, records-per-request-avg type, client-id, topic
KafkaConsumerConsumerFetchManagerMetricsTopicPartition kafka.consumer:type=consumer-fetch-manager-metrics,client-id=*,topic=*,partition=* preferred-read-replica, records-lag, records-lag-avg, records-lag-max, records-lead, records-lead-avg, records-lead-min type, client-id, topic, partition
KafkaConsumerConsumerMetrics kafka.consumer:type=consumer-metrics,client-id=* connection-close-rate, connection-close-total, connection-count, connection-creation-rate, connection-creation-total, failed-authentication-rate, failed-authentication-total, failed-reauthentication-rate, failed-reauthentication-total, incoming-byte-rate, incoming-byte-total, io-ratio, io-time-ns-avg, io-wait-ratio, io-wait-time-ns-avg, io-waittime-total, iotime-total, last-poll-seconds-ago, network-io-rate, network-io-total, outgoing-byte-rate, outgoing-byte-total, poll-idle-ratio-avg, reauthentication-latency-avg, reauthentication-latency-max, request-rate, request-size-avg, request-size-max, request-total, response-rate, response-total, select-rate, select-total, successful-authentication-no-reauth-total, successful-authentication-rate, successful-authentication-total, successful-reauthentication-rate, successful-reauthentication-total, time-between-poll-avg, time-between-poll-max type, client-id
KafkaConsumerConsumerNodeMetrics kafka.consumer:type=consumer-node-metrics,client-id=*,node-id=* incoming-byte-rate, incoming-byte-total, outgoing-byte-rate, outgoing-byte-total, request-latency-avg, request-latency-max, request-rate, request-total, request-size-avg, request-size-max, response-rate, response-total type, client-id, node-id
KafkaConsumerKafkaMetricsCount kafka.consumer:type=kafka-metrics-count,client-id=* count type, client-id
JavaLangOperatingSystem java.lang:type=OperatingSystem OpenFileDescriptorCount, MaxFileDescriptorCount, CommittedVirtualMemorySize, TotalSwapSpaceSize, FreeSwapSpaceSize, ProcessCpuTime, FreePhysicalMemorySize, TotalPhysicalMemorySize, SystemCpuLoad, ProcessCpuLoad, Arch, Version, SystemLoadAverage, AvailableProcessors, Name, ObjectName type
JavaLangMemory java.lang:type=Memory HeapMemoryUsage, NonHeapMemoryUsage type
JavaLangMemoryPool java.lang:type=MemoryPool,name=* PeakUsage, UsageThreshold, UsageThresholdExceeded, UsageThresholdCount, UsageThresholdSupported, CollectionUsageThreshold, CollectionUsageThresholdExceeded, CollectionUsageThresholdCount, CollectionUsage, CollectionUsageThresholdSupported type, name
JavaLangThreading java.lang:type=Threading CurrentThreadCpuTime, CurrentThreadUserTime, DaemonThreadCount, PeakThreadCount, ThreadCount, TotalStartedThreadCount type
JavaLangRuntime java.lang:type=Runtime Uptime type
JavaLangGarbageCollector java.lang:type=GarbageCollector,name=* CollectionCount, CollectionTime, LastGcInfo, MemoryPoolNames type, name
JavaNioBufferPool java.nio:type=BufferPool,name=* Count, MemoryUsed, TotalCapacity type, name

Apache Kafka Producers

Influx Measurement Mbean Object Attributes (Influx fields) Influx Tags
KafkaProducerAppInfoClientId kafka.producer:type=app-info,client-id=* commit-id, start-time-ms, version type, client-id
KafkaProducerAppInfoId kafka.producer:type=app-info,id=* Version, CommitId, StartTimeMs type, id
KafkaProducerKafkaMetricsCount kafka.producer:type=kafka-metrics-count,client-id=* count type, client-id
KafkaProducerProducerMetrics kafka.producer:type=producer-metrics,client-id=* batch-size-avg, batch-size-max, batch-split-rate, batch-split-total, buffer-available-bytes, buffer-exhausted-rate, buffer-exhausted-total, buffer-total-bytes, bufferpool-wait-ratio, bufferpool-wait-time-total, compression-rate-avg, connection-close-rate, connection-close-total, connection-count, connection-creation-rate, connection-creation-total, failed-authentication-rate, failed-authentication-total, failed-reauthentication-rate, failed-reauthentication-total, incoming-byte-rate, incoming-byte-total, io-ratio, io-time-ns-avg, io-wait-ratio, io-wait-time-ns-avg, io-waittime-total, iotime-total, metadata-age, network-io-rate, network-io-total, outgoing-byte-rate, outgoing-byte-total, produce-throttle-time-avg, produce-throttle-time-max, reauthentication-latency-avg, reauthentication-latency-max, record-error-rate, record-error-total, record-queue-time-avg, record-queue-time-max, record-retry-rate, record-retry-total, record-send-rate, record-send-total, record-size-avg, record-size-max, records-per-request-avg, request-latency-avg, request-latency-max, request-rate, request-size-avg, request-size-max, request-total, requests-in-flight, response-rate, response-total, select-rate, select-total, successful-authentication-no-reauth-total, successful-authentication-rate, successful-authentication-total, successful-reauthentication-rate, successful-reauthentication-total, waiting-threads type, client-id
KafkaProducerProducerNodeMetrics kafka.producer:type=producer-node-metrics,client-id=*,node-id=* incoming-byte-rate, incoming-byte-total, outgoing-byte-rate, outgoing-byte-total, request-latency-avg, request-latency-max, request-rate, request-size-avg, request-size-max, request-total, response-rate, response-total type, client-id, node-id
KafkaProducerProducerTopicMetrics kafka.producer:type=producer-topic-metrics,client-id=*,topic=* byte-rate, byte-total, compression-rate, record-error-rate, record-error-total, record-retry-rate, record-retry-total, record-send-rate, record-send-total type, client-id, topic
JavaLangOperatingSystem java.lang:type=OperatingSystem OpenFileDescriptorCount, MaxFileDescriptorCount, CommittedVirtualMemorySize, TotalSwapSpaceSize, FreeSwapSpaceSize, ProcessCpuTime, FreePhysicalMemorySize, TotalPhysicalMemorySize, SystemCpuLoad, ProcessCpuLoad, Arch, Version, SystemLoadAverage, AvailableProcessors, Name, ObjectName type
JavaLangMemory java.lang:type=Memory HeapMemoryUsage, NonHeapMemoryUsage type
JavaLangMemoryPool java.lang:type=MemoryPool,name=* PeakUsage, UsageThreshold, UsageThresholdExceeded, UsageThresholdCount, UsageThresholdSupported, CollectionUsageThreshold, CollectionUsageThresholdExceeded, CollectionUsageThresholdCount, CollectionUsage, CollectionUsageThresholdSupported type, name
JavaLangThreading java.lang:type=Threading CurrentThreadCpuTime, CurrentThreadUserTime, DaemonThreadCount, PeakThreadCount, ThreadCount, TotalStartedThreadCount type
JavaLangRuntime java.lang:type=Runtime Uptime type
JavaLangGarbageCollector java.lang:type=GarbageCollector,name=* CollectionCount, CollectionTime, LastGcInfo, MemoryPoolNames type, name
JavaNioBufferPool java.nio:type=BufferPool,name=* Count, MemoryUsed, TotalCapacity type, name

Apache Kafka Streams

Influx Measurement Mbean Object Attributes (Influx fields) Influx Tags
KafkaStreamsStreamMetrics kafka.streams:type=stream-metrics,client-id=* version, commit-id, application-id, topology-description, state type, client-id
KafkaStreamsStreamThreadMetrics kafka.streams:type=stream-thread-metrics,thread-id=* commit-latency-avg, commit-latency-max, poll-latency-avg, poll-latency-max, process-latency-avg, process-latency-max, punctuate-latency-avg, punctuate-latency-max, commit-rate, commit-total, poll-rate, poll-total, process-rate, process-total, punctuate-rate, punctuate-total, task-created-rate, task-created-total, task-closed-rate, task-closed-total type, thread-id
KafkaStreamsStreamTaskMetrics kafka.streams:type=stream-task-metrics,thread-id=*,task-id=* process-latency-avg, process-latency-max, process-rate, process-total, commit-latency-avg, commit-latency-max, commit-rate, commit-total, record-lateness-avg, record-lateness-max, enforced-processing-rate, enforced-processing-total, dropped-records-rate, dropped-records-total, punctuate-rate, punctuate-total, task-created-rate, task-created-total, task-closed-rate, task-closed-total type, thread-id, task-id
KafkaStreamsStreamProcessorNodeMetrics kafka.streams:type=stream-processor-node-metrics,thread-id=*,task-id=*,processor-node-id=* process-rate, process-total, suppression-emit-rate, suppression-emit-total type, thread-id, task-id, processor-node-id
KafkaStreamsStreamStateMetricsInMemoryState kafka.streams:type=stream-state-metrics,thread-id=*,task-id=*,in-memory-state-id=* put-latency-avg, put-latency-max, put-if-absent-latency-avg, put-if-absent-latency-max, get-latency-avg, get-latency-max, delete-latency-avg, delete-latency-max, put-all-latency-avg, put-all-latency-max, all-latency-avg, all-latency-max, range-latency-avg, range-latency-max, flush-latency-avg, flush-latency-max, restore-latency-avg, restore-latency-max, put-rate, put-if-absent-rate, get-rate, delete-rate, put-all-rate, all-rate, range-rate, flush-rate, restore-rate, suppression-buffer-size-avg, suppression-buffer-size-max, suppression-buffer-count-avg, suppression-buffer-count-max type, thread-id, task-id, in-memory-state-id
KafkaStreamsStreamStateMetricsInMemoryLruState kafka.streams:type=stream-state-metrics,thread-id=*,task-id=*,in-memory-lru-state-id=* put-latency-avg, put-latency-max, put-if-absent-latency-avg, put-if-absent-latency-max, get-latency-avg, get-latency-max, delete-latency-avg, delete-latency-max, put-all-latency-avg, put-all-latency-max, all-latency-avg, all-latency-max, range-latency-avg, range-latency-max, flush-latency-avg, flush-latency-max, restore-latency-avg, restore-latency-max, put-rate, put-if-absent-rate, get-rate, delete-rate, put-all-rate, all-rate, range-rate, flush-rate, restore-rate, suppression-buffer-size-avg, suppression-buffer-size-max, suppression-buffer-count-avg, suppression-buffer-count-max type, thread-id, task-id, in-memory-lru-state-id
KafkaStreamsStreamStateMetricsInMemoryWindowState kafka.streams:type=stream-state-metrics,thread-id=*,task-id=*,in-memory-window-state-id=* put-latency-avg, put-latency-max, put-if-absent-latency-avg, put-if-absent-latency-max, get-latency-avg, get-latency-max, delete-latency-avg, delete-latency-max, put-all-latency-avg, put-all-latency-max, all-latency-avg, all-latency-max, range-latency-avg, range-latency-max, flush-latency-avg, flush-latency-max, restore-latency-avg, restore-latency-max, put-rate, put-if-absent-rate, get-rate, delete-rate, put-all-rate, all-rate, range-rate, flush-rate, restore-rate, suppression-buffer-size-avg, suppression-buffer-size-max, suppression-buffer-count-avg, suppression-buffer-count-max type, thread-id, task-id, in-memory-window-state-id
KafkaStreamsStreamStateMetricsInMemorySuppression kafka.streams:type=stream-state-metrics,thread-id=*,task-id=*,in-memory-suppression-id=* put-latency-avg, put-latency-max, put-if-absent-latency-avg, put-if-absent-latency-max, get-latency-avg, get-latency-max, delete-latency-avg, delete-latency-max, put-all-latency-avg, put-all-latency-max, all-latency-avg, all-latency-max, range-latency-avg, range-latency-max, flush-latency-avg, flush-latency-max, restore-latency-avg, restore-latency-max, put-rate, put-if-absent-rate, get-rate, delete-rate, put-all-rate, all-rate, range-rate, flush-rate, restore-rate, suppression-buffer-size-avg, suppression-buffer-size-max, suppression-buffer-count-avg, suppression-buffer-count-max type, thread-id, task-id, in-memory-suppression-id
KafkaStreamsStreamStateMetricsRocksdbState kafka.streams:type=stream-state-metrics,thread-id=*,task-id=*,rocksdb-state-id=* put-latency-avg, put-latency-max, put-if-absent-latency-avg, put-if-absent-latency-max, get-latency-avg, get-latency-max, delete-latency-avg, delete-latency-max, put-all-latency-avg, put-all-latency-max, all-latency-avg, all-latency-max, range-latency-avg, range-latency-max, flush-latency-avg, flush-latency-max, restore-latency-avg, restore-latency-max, put-rate, put-if-absent-rate, get-rate, delete-rate, put-all-rate, all-rate, range-rate, flush-rate, restore-rate, suppression-buffer-size-avg, suppression-buffer-size-max, suppression-buffer-count-avg, suppression-buffer-count-max, bytes-written-rate, bytes-written-total, bytes-read-rate, bytes-read-total, memtable-bytes-flushed-rate, memtable-bytes-flushed-total, memtable-hit-ratio, block-cache-data-hit-ratio, block-cache-index-hit-ratio, block-cache-filter-hit-ratio, write-stall-duration-avg, write-stall-duration-total, bytes-read-compaction-rate, bytes-written-compaction-rate, number-open-files, number-file-errors-total type, thread-id, task-id, rocksdb-state-id
KafkaStreamsStreamStateMetricsRocksdbWindowState kafka.streams:type=stream-state-metrics,thread-id=*,task-id=*,rocksdb-window-state-id=* put-latency-avg, put-latency-max, put-if-absent-latency-avg, put-if-absent-latency-max, get-latency-avg, get-latency-max, delete-latency-avg, delete-latency-max, put-all-latency-avg, put-all-latency-max, all-latency-avg, all-latency-max, range-latency-avg, range-latency-max, flush-latency-avg, flush-latency-max, restore-latency-avg, restore-latency-max, put-rate, put-if-absent-rate, get-rate, delete-rate, put-all-rate, all-rate, range-rate, flush-rate, restore-rate, suppression-buffer-size-avg, suppression-buffer-size-max, suppression-buffer-count-avg, suppression-buffer-count-max, bytes-written-rate, bytes-written-total, bytes-read-rate, bytes-read-total, memtable-bytes-flushed-rate, memtable-bytes-flushed-total, memtable-hit-ratio, block-cache-data-hit-ratio, block-cache-index-hit-ratio, block-cache-filter-hit-ratio, write-stall-duration-avg, write-stall-duration-total, bytes-read-compaction-rate, bytes-written-compaction-rate, number-open-files, number-file-errors-total type, thread-id, task-id, rocksdb-window-state-id
KafkaStreamsStreamStateMetricsRocksdbSessionState kafka.streams:type=stream-state-metrics,thread-id=*,task-id=*,rocksdb-session-state-id=* put-latency-avg, put-latency-max, put-if-absent-latency-avg, put-if-absent-latency-max, get-latency-avg, get-latency-max, delete-latency-avg, delete-latency-max, put-all-latency-avg, put-all-latency-max, all-latency-avg, all-latency-max, range-latency-avg, range-latency-max, flush-latency-avg, flush-latency-max, restore-latency-avg, restore-latency-max, put-rate, put-if-absent-rate, get-rate, delete-rate, put-all-rate, all-rate, range-rate, flush-rate, restore-rate, suppression-buffer-size-avg, suppression-buffer-size-max, suppression-buffer-count-avg, suppression-buffer-count-max, bytes-written-rate, bytes-written-total, bytes-read-rate, bytes-read-total, memtable-bytes-flushed-rate, memtable-bytes-flushed-total, memtable-hit-ratio, block-cache-data-hit-ratio, block-cache-index-hit-ratio, block-cache-filter-hit-ratio, write-stall-duration-avg, write-stall-duration-total, bytes-read-compaction-rate, bytes-written-compaction-rate, number-open-files, number-file-errors-total type, thread-id, task-id, rocksdb-session-state-id
KafkaStreamsStreamRecordCacheMetrics kafka.streams:type=stream-record-cache-metrics,thread-id=*,task-id=*,record-cache-id=* hit-ratio-avg, hit-ratio-min, hit-ratio-max type, thread-id, task-id, record-cache-id
JavaLangOperatingSystem java.lang:type=OperatingSystem OpenFileDescriptorCount, MaxFileDescriptorCount, CommittedVirtualMemorySize, TotalSwapSpaceSize, FreeSwapSpaceSize, ProcessCpuTime, FreePhysicalMemorySize, TotalPhysicalMemorySize, SystemCpuLoad, ProcessCpuLoad, Arch, Version, SystemLoadAverage, AvailableProcessors, Name, ObjectName type
JavaLangMemory java.lang:type=Memory HeapMemoryUsage, NonHeapMemoryUsage type
JavaLangMemoryPool java.lang:type=MemoryPool,name=* PeakUsage, UsageThreshold, UsageThresholdExceeded, UsageThresholdCount, UsageThresholdSupported, CollectionUsageThreshold, CollectionUsageThresholdExceeded, CollectionUsageThresholdCount, CollectionUsage, CollectionUsageThresholdSupported type, name
JavaLangThreading java.lang:type=Threading CurrentThreadCpuTime, CurrentThreadUserTime, DaemonThreadCount, PeakThreadCount, ThreadCount, TotalStartedThreadCount type
JavaLangRuntime java.lang:type=Runtime Uptime type
JavaLangGarbageCollector java.lang:type=GarbageCollector,name=* CollectionCount, CollectionTime, LastGcInfo, MemoryPoolNames type, name
JavaNioBufferPool java.nio:type=BufferPool,name=* Count, MemoryUsed, TotalCapacity type, name

Apache ZooKeeper Nodes

Influx Measurement Mbean Object Attributes (Influx fields) Influx Tags
ZooKeeperMetrics org.apache.ZooKeeperService:name0=ReplicatedServer_id{0},name1=replica.{0},name2=* ElectionTimeTaken, TickTime, MinSessionTimeout, MaxSessionTimeout, MinRequestLatency, AvgRequestLatency, MaxRequestLatency, FsyncThresholdExceedCount, SecureClientAddress, JuteMaxBufferSize, LastClientResponseSize, MinClientResponseSize, MaxClientResponseSize, MaxClientCnxnsPerHost, ClientPort, StartTime, Version, NumAliveConnections, OutstandingRequests, PacketsReceived, PacketsSent, DataDirSize, LogDirSize, SecureClientPort, TxnLogElapsedSyncTime, LastProposalSize, MinProposalSize, MaxProposalSize, CurrentZxid, LastQueuedZxid, PendingRevalidationCount, QuorumAddress name0, name1, name2
ZooKeeperMetricsInMemoryData org.apache.ZooKeeperService:name0=ReplicatedServer_id{0},name1=replica.{0},name2=*,name3=InMemoryDataTree LastZxid, NodeCount, WatchCount name0, name1, name2, name3
JavaLangOperatingSystem java.lang:type=OperatingSystem OpenFileDescriptorCount, MaxFileDescriptorCount, CommittedVirtualMemorySize, TotalSwapSpaceSize, FreeSwapSpaceSize, ProcessCpuTime, FreePhysicalMemorySize, TotalPhysicalMemorySize, SystemCpuLoad, ProcessCpuLoad, Arch, Version, SystemLoadAverage, AvailableProcessors, Name, ObjectName type
JavaLangMemory java.lang:type=Memory HeapMemoryUsage, NonHeapMemoryUsage type
JavaLangMemoryPool java.lang:type=MemoryPool,name=* PeakUsage, UsageThreshold, UsageThresholdExceeded, UsageThresholdCount, UsageThresholdSupported, CollectionUsageThreshold, CollectionUsageThresholdExceeded, CollectionUsageThresholdCount, CollectionUsage, CollectionUsageThresholdSupported type, name
JavaLangThreading java.lang:type=Threading CurrentThreadCpuTime, CurrentThreadUserTime, DaemonThreadCount, PeakThreadCount, ThreadCount, TotalStartedThreadCount type
JavaLangRuntime java.lang:type=Runtime Uptime type
JavaLangGarbageCollector java.lang:type=GarbageCollector,name=* CollectionCount, CollectionTime, LastGcInfo, MemoryPoolNames type, name
JavaNioBufferPool java.nio:type=BufferPool,name=* Count, MemoryUsed, TotalCapacity type, name