Which partitioning strategy in Kafka is most suitable when you need messages with the same key to be processed by the same consumer instance?
Random Partitioning
Time-based Partitioning
Round Robin Partitioning
Key-based Partitioning
What is the primary function of Kafka Streams?
Guaranteeing exactly-once message delivery
Storing and persisting streaming data
Performing real-time data analysis and transformations on streams
Managing cluster resources for Kafka brokers
Which tool is used to perform controlled shutdown and removal of a broker from a Kafka cluster?
kafka-topics.sh
kafka-reassign-partitions.sh
kafka-config.sh
kafka-preferred-replica-election.sh
What is the recommended minimum number of brokers for a production-ready Kafka cluster to ensure high availability and fault tolerance?
1
3
4
2
What tool is commonly used to manage and monitor Kafka Connect connectors?
Kafka Streams API.
Kafka Control Center.
ZooKeeper CLI.
Kafka Connect REST API.
What is the role of a Kafka Controller in a cluster?
Monitoring and managing the health of brokers
Handling data replication between brokers
Managing message consumption rates
Performing load balancing of messages
Which mechanism is fundamental to Kafka's zero-copy technology for transferring data between the broker and the operating system?
Data deduplication
Data encryption
Message compression
Direct memory access (DMA)
What happens to a consumer's offset when it encounters an error while processing a message?
The consumer is removed from the consumer group.
The offset is automatically reset to the beginning of the partition.
The message is discarded and the offset is advanced.
The offset is not updated until the message is successfully processed.
Which of the following is a benefit of using a dedicated monitoring system for Kafka instead of relying solely on JMX?
Reduced load on Kafka brokers
Both A and C
Simplified access to metrics without requiring a JMX client
Eliminates the need for JMX configuration
How does Kafka ensure message ordering within a partition?
By assigning sequential timestamps to messages
By using message keys for sorting
By appending messages sequentially to the log
By employing a priority queue mechanism