Which mechanism is fundamental to Kafka's zero-copy technology for transferring data between the broker and the operating system?
Data encryption
Direct memory access (DMA)
Message compression
Data deduplication
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 Kafka Streams API is specifically designed for performing windowed aggregations?
reduce()
groupBy()
transform()
filter()
What is the primary purpose of log compaction in Kafka?
Optimizing message routing
Deleting old messages based on time
Retaining the latest value for each key
Improving message compression
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
Round Robin Partitioning
Key-based Partitioning
Time-based Partitioning
How does Grafana complement Prometheus in Kafka monitoring?
It replaces Prometheus as the primary metric storage
It provides customizable dashboards and visualizations for Kafka metrics stored in Prometheus
It sends alerts based on Kafka metrics collected by JMX
It acts as a JMX client to collect metrics from Kafka brokers
In Kafka's architecture, which component is responsible for storing and replicating message data?
Producer
Broker
ZooKeeper
Consumer
What is a key difference between synchronous and asynchronous producers in Kafka?
Synchronous producers are only used for high-throughput scenarios, while asynchronous producers are suitable for low-throughput cases.
Synchronous producers send messages to multiple topics, while asynchronous producers send to a single topic.
Synchronous producers use a push-based model, while asynchronous producers use a pull-based model.
Synchronous producers block until the broker acknowledges message receipt, while asynchronous producers send messages without waiting for confirmation.
Which of the following is the function of a 'Sink Connector' in Kafka Connect?
It aggregates data from multiple Kafka topics into a single topic.
It filters messages in a Kafka topic based on predefined criteria.
It retrieves data from a Kafka topic and writes it to an external system.
It replicates data between different Kafka clusters.
In a Kafka topic with multiple partitions and a replication factor of 3, what is the minimum number of brokers required for fault tolerance if one broker can fail?
6
3
2
1