10/218 questions · Unlock full access
Q1

An administrator is investigating a Kafka cluster where producers are experiencing high latency and frequent timeouts. The topic in question has a replication factor of 3 and `min.insync.replicas` is set to 2. Monitoring reveals that one of the three brokers hosting partitions for this topic is consistently exhibiting high disk I/O wait times, causing it to frequently fall out of the In-Sync Replica (ISR) set. What is the most effective initial action to mitigate the producer latency while ensuring data durability is not compromised below the configured minimum?

Q2

A financial services company is deploying a new Kafka cluster using KRaft mode. The architecture calls for a dedicated controller quorum of 5 nodes for high availability. What is the correct value for the `controller.quorum.voters` configuration property on each controller node?

Q3Multiple answers

An administrator needs to enforce client quotas to prevent a single misbehaving application from monopolizing cluster resources. The goal is to limit the network bandwidth consumed by a specific user, 'app-user-1'. Which two properties must be configured to enforce a produce quota for this user? (Select TWO)

Q4

True or False: When `unclean.leader.election.enable` is set to `true` for a topic, it is possible for messages that were not replicated to all in-sync replicas to be lost during a leader failover.

Q5

A new administrator is tasked with setting up log compaction on a topic named `user-profiles`. The goal is to retain only the most recent value for each user ID, which is used as the message key. After enabling compaction, the administrator observes that old records are not being removed, and the topic's log segments are growing indefinitely. Which configuration setting is the most likely cause of this issue?

Q6

An administrator is setting up a Kafka Connect cluster in distributed mode to sink data from a Kafka topic to a database. To ensure high availability and fault tolerance, how does the Connect cluster handle a worker node failure?

Q7

You are designing a security policy for a multi-tenant Kafka cluster. You need to grant a team, represented by the user principal `user:data-science`, the ability to consume from any topic prefixed with `ds-`, but prevent them from consuming from any other topics. Which ACL entry correctly implements this policy?

Q8

During a routine check, an administrator notices that the consumer lag for a critical application is steadily increasing. The application runs a single consumer as part of a consumer group subscribed to a topic with 12 partitions. The consumer's `max.poll.records` is set to 500 (the default), and `max.poll.interval.ms` is 300000 (5 minutes). Logs show that the consumer is not being removed from the group, but processing a single batch of 500 records takes, on average, 6 minutes. What is the most direct cause of the increasing consumer lag?

Q9

Which of the following Kafka command-line tools would an administrator use to check for under-replicated partitions in a cluster?

Q10

A media company uses Kafka to process video streams. They want to deploy a cluster across three availability zones (AZs) for high availability. To ensure that replicas for any given partition are spread across these AZs, which broker configuration property must be set?