What is the recommended minimum number of brokers for a production-ready Kafka cluster to ensure high availability and fault tolerance?
3
1
2
4
When adding a new broker to an existing Kafka cluster, what process ensures that the partitions are evenly distributed across all available brokers?
Broker Synchronization
Load Balancing
Rebalancing
Data Replication
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 Kafka's architecture, which component is responsible for storing and replicating message data?
Consumer
Broker
ZooKeeper
Producer
Which component in Kafka is responsible for managing the state of tasks and ensuring fault tolerance within a Kafka Streams application?
Kafka Connect
Kafka Streams API
Kafka Producer
Which scenario would benefit from using a synchronous Kafka producer?
Logging system where message loss is acceptable.
Financial transaction processing where guaranteed message delivery is paramount.
Real-time data streaming where latency is critical.
High-volume sensor data ingestion where throughput is a primary concern.
What is the primary purpose of Kafka Connect within the Kafka ecosystem?
Managing and monitoring the health of Kafka clusters.
Simplifying the integration of data between Kafka and external systems.
Real-time stream processing of data within Kafka topics.
Providing a scalable and distributed messaging platform.
What is the significance of the 'unclean.leader.election.enable' configuration parameter during broker failures?
It controls the replication factor for partitions.
It defines the time a broker is considered dead before triggering a leader election.
It ensures no data loss during leader election but might increase unavailability.
It allows for faster leader election but might lead to data loss.
In KSQL, what is a 'STREAM' analogous to in traditional database terminology?
A table
A view
A trigger
A stored procedure
Which tool is used to perform controlled shutdown and removal of a broker from a Kafka cluster?
kafka-reassign-partitions.sh
kafka-preferred-replica-election.sh
kafka-config.sh
kafka-topics.sh