Kafka Manager/UI tools - Practice Problems & Coding Challenges

Challenge - 5 Problems

❓ Predict Output

intermediate

What is the output of this Kafka Manager topic list command?

You run the following command in Kafka Manager CLI to list topics in a cluster:

kafka-manager --list-topics --cluster my-cluster

Assuming the cluster has topics: orders, payments, users, what will be the output?

Kafka

kafka-manager --list-topics --cluster my-cluster

A

orders
payments
users

B [orders, payments, users]

C {orders, payments, users}

D Topic list: orders, payments, users

💡 Hint

Think about how CLI tools usually print lists line by line.

Kafka Manager CLI typically prints each topic name on its own line without brackets or extra text.

🧠 Conceptual

intermediate

Which UI tool allows you to monitor Kafka consumer lag visually?

You want to see how far behind your consumers are from the latest messages in Kafka. Which Kafka UI tool is designed to show consumer lag clearly?

A Kafka MirrorMaker

B Kafka Connect

C Kafka Streams

D Kafka Manager

💡 Hint

This tool is a web UI for managing and monitoring Kafka clusters.

Kafka Manager provides a web interface that shows consumer groups and their lag in real time.

🔧 Debug

advanced

Why does Kafka Manager fail to connect to the cluster?

You configured Kafka Manager with the cluster address but it shows connection errors. Which of these is the most likely cause?

Kafka

cluster.address=PLAINTEXT://kafka-broker:9092
zk.address=zk1:2181,zk2:2181

A Kafka Manager needs the broker IP, not hostname

B Kafka Manager requires ZooKeeper address, not just Kafka broker address

C Kafka Manager cannot connect because the port 9092 is blocked by firewall

D The cluster.address should use SSL protocol instead of PLAINTEXT

💡 Hint

Kafka Manager uses ZooKeeper to discover cluster metadata.

Kafka Manager connects to ZooKeeper to get cluster info; missing or wrong ZooKeeper address causes connection failure.

📝 Syntax

advanced

Identify the correct JSON format for Kafka Manager cluster config

Which JSON snippet correctly defines a Kafka cluster configuration for Kafka Manager?

A { name: "prod-cluster", zkHosts: "zk1:2181,zk2:2181", kafkaVersion: "2.8.0" }

B { 'name': 'prod-cluster', 'zkHosts': 'zk1:2181,zk2:2181', 'kafkaVersion': '2.8.0' }

C { "name": "prod-cluster", "zkHosts": "zk1:2181,zk2:2181", "kafkaVersion": "2.8.0" }

D { "name" => "prod-cluster", "zkHosts" => "zk1:2181,zk2:2181", "kafkaVersion" => "2.8.0" }

💡 Hint

JSON keys and string values must use double quotes.

Valid JSON requires double quotes for keys and string values; no single quotes or arrows.

🚀 Application

expert

How to automate topic creation with Kafka Manager API?

You want to create a new topic named 'logs' with 3 partitions and replication factor 2 using Kafka Manager's REST API. Which HTTP request body is correct?

A { "name": "logs", "numPartitions": 3, "replicationFactor": 2 }

B { "topic": "logs", "partitions": 3, "replicationFactor": 2 }

C { "topicName": "logs", "partitionsCount": 3, "replicas": 2 }

D { "topic": "logs", "partitions": "3", "replicationFactor": "2" }

💡 Hint

Check Kafka Manager API docs for exact field names and types.

Kafka Manager API expects 'name' for topic name, 'numPartitions' as integer, and 'replicationFactor' as integer.