Key broker metrics in Kafka - Practice Problems & Coding Challenges

Challenge - 5 Problems

❓ Predict Output

intermediate

Output of Kafka broker metric query

Given the following Kafka broker metrics query snippet, what is the output when querying the metric kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec,topic=TestTopic?

Kafka

kafka-run-class kafka.tools.JmxTool --jmx-url service:jmx:rmi:///jndi/rmi://localhost:9999/jmxrmi --object-name kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec,topic=TestTopic

A {"Count": 0, "MeanRate": 0.0, "OneMinuteRate": 0.0}

B {"Count": 1500, "MeanRate": 10.5, "OneMinuteRate": 12.3}

C Error: Metric kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec,topic=TestTopic not found

D SyntaxError: Invalid JMX URL format

💡 Hint

Check the metric name and topic parameter carefully.

The metric kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec,topic=TestTopic returns the count and rates of messages received per second for the topic 'TestTopic'. The output shows actual metric values.

🧠 Conceptual

intermediate

Understanding Kafka broker metric 'UnderReplicatedPartitions'

What does the Kafka broker metric UnderReplicatedPartitions indicate?

A The number of partitions currently being created

B The total number of partitions in the broker

C The number of partitions that have fewer replicas in sync than the configured replication factor

D The number of partitions that have no leader assigned

💡 Hint

Think about replication health and data safety.

UnderReplicatedPartitions counts partitions where some replicas are not in sync, indicating potential data loss risk if the leader fails.

🔧 Debug

advanced

Identify the error in Kafka broker metric retrieval code

What error will the following code produce when trying to fetch the broker metric kafka.network:type=RequestMetrics,name=RequestsPerSec,request=Produce?

from kafka import KafkaAdminClient

admin_client = KafkaAdminClient(bootstrap_servers='localhost:9092')
metric = admin_client.get_metric('kafka.network:type=RequestMetrics,name=RequestsPerSec,request=Produce')
print(metric)

A AttributeError: 'KafkaAdminClient' object has no attribute 'get_metric'

B {'Count': 500, 'MeanRate': 20.0, 'OneMinuteRate': 18.5}

C ConnectionError: Failed to connect to localhost:9092

D TypeError: get_metric() missing 1 required positional argument

💡 Hint

Check if KafkaAdminClient supports metric retrieval directly.

KafkaAdminClient does not have a method named get_metric. Metrics are accessed via JMX or other monitoring tools, not via this client.

📝 Syntax

advanced

Correct syntax for filtering Kafka broker metrics by topic

Which of the following JMX object names correctly filters the Kafka broker metric BytesInPerSec for the topic myTopic?

A kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec?topic=myTopic

B kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec;topic=myTopic

C kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec/topic=myTopic

D kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec,topic=myTopic

💡 Hint

JMX object names use commas to separate key-value pairs.

JMX object names separate key-value pairs with commas. The correct syntax uses commas, not semicolons, slashes, or question marks.

🚀 Application

expert

Calculate total messages in per second across all topics

You have the following metrics for two topics on a Kafka broker: - kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec,topic=TopicA: Count=1000, MeanRate=15.0 - kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec,topic=TopicB: Count=2000, MeanRate=25.0 What is the total MeanRate of messages in per second across both topics?

A 40.0

B 25.0

C 15.0

D 3000

💡 Hint

Add the MeanRate values for both topics.

MeanRate is the average messages per second. Adding 15.0 and 25.0 gives 40.0 total messages per second.