What is the primary purpose of log compaction in Kafka?
Improving message compression
Deleting old messages based on time
Retaining the latest value for each key
Optimizing message routing
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
Key-based Partitioning
Time-based Partitioning
Round Robin Partitioning
What is the primary purpose of ZooKeeper in a multi-node Kafka cluster?
Compressing messages for efficient storage
Storing and serving message data
Managing consumer group offsets
Maintaining cluster metadata and ensuring consistency
In Kafka Connect, what is the role of a 'Source Connector'?
It transforms data within a Kafka topic before sending it to a sink.
It routes messages between different topics within a Kafka cluster.
It consumes data from an external system and publishes it to a Kafka topic.
It writes data from a Kafka topic to an external system.
What does JMX stand for in the context of Kafka monitoring?
Just Monitor XML
Java Message eXport
JSON Metric eXchange
Java Management eXtensions
Which Kafka Streams API is specifically designed for performing windowed aggregations?
transform()
reduce()
filter()
groupBy()
How does Kafka ensure message ordering within a partition?
By assigning sequential timestamps to messages
By employing a priority queue mechanism
By appending messages sequentially to the log
By using message keys for sorting
What is the significance of 'Exactly Once Semantics' in Kafka Streams?
It ensures that records are processed in the exact order they were produced.
It guarantees that each record is processed at least once.
It prevents duplicate processing of records even in the event of failures.
It prioritizes speed over accuracy in data processing.
What is the primary method used by a Kafka Producer to send messages to a Kafka topic?
send()
push()
deliver()
transmit()
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