How do you specify the message format (e.g., JSON, Avro) when consuming messages with the Kafka console consumer?
--message-format
--value-deserializer
--key-serializer
--consumer-format
How do you start a Kafka broker after installation?
By simply starting the ZooKeeper service
Kafka automatically starts with the operating system
By running the 'kafka-server-start.sh' script
Through a web interface provided by Kafka
What is a 'Partition' in the context of Kafka topics?
A configuration setting that determines message retention time.
A separate copy of the entire topic data for redundancy.
A logical grouping of messages within a topic for parallel processing.
A security mechanism to control access to specific topics.
What is the significance of the replication.factor setting in topic configuration?
replication.factor
Configures the message delivery semantics (at-least-once, at-most-once).
Specifies the maximum message size allowed in the topic.
Sets the compression algorithm for messages.
Determines the number of brokers where topic data is replicated.
How does Kafka achieve scalability?
By distributing data across multiple brokers
By using a single, powerful server
By limiting the number of topics allowed
Through complex data compression algorithms
What is the role of ZooKeeper in a Kafka cluster?
Consuming messages from topics
Managing and coordinating Kafka brokers
Performing data aggregation
Storing message data
Which configuration parameter determines the number of partitions a topic will have?
partition.count
topic.partitions
num.partitions
How are messages within a Kafka topic organized?
Divided into ordered, immutable sequences called partitions
Sorted by message key
Randomly distributed
Grouped by consumer group
What is the primary function of a Kafka producer?
Reading messages from a topic
Storing messages persistently
Managing user permissions
Publishing messages to a topic
Which of these is NOT a common use case for Kafka?
Storing large files like images and videos.
Data pipelines for ingesting and processing data.
Building a message queue for asynchronous communication.
Real-time data analytics and monitoring.