In Kafka, which configuration setting controls the duration for which message acknowledgments from consumers are tracked?
message.timeout.ms
offsets.retention.minutes
group.max.session.timeout.ms
replica.lag.time.max.ms
What is the role of a Kafka Controller in a cluster?
Performing load balancing of messages
Managing message consumption rates
Monitoring and managing the health of brokers
Handling data replication between brokers
Which scenario would benefit from using a synchronous Kafka producer?
Real-time data streaming where latency is critical.
Logging system where message loss is acceptable.
Financial transaction processing where guaranteed message delivery is paramount.
High-volume sensor data ingestion where throughput is a primary concern.
How does Kafka Streams ensure fault tolerance during stateful processing?
By storing state information only in memory for fast recovery.
By replicating the state store across multiple nodes in the cluster.
By relying on external databases for state persistence.
By disabling stateful operations during network partitions.
Which of the following is a valid KSQL command to create a new stream from an existing Kafka topic named 'sensor_data'?
CREATE TABLE sensor_data_stream AS SELECT * FROM sensor_data;
CREATE STREAM sensor_data_stream (sensorId INT, value DOUBLE) WITH (kafka_topic='sensor_data', value_format='JSON');
INSERT INTO sensor_data_stream SELECT * FROM sensor_data;
DEFINE STREAM sensor_data_stream (sensorId INT, value DOUBLE) WITH (topic='sensor_data', format='JSON');
What is the primary method used by a Kafka Producer to send messages to a Kafka topic?
send()
deliver()
push()
transmit()
What is the role of Prometheus in Kafka monitoring?
It analyzes Kafka logs to identify performance bottlenecks
It provides a user interface for visualizing Kafka metrics
It acts as a message broker between Kafka and monitoring tools
It collects and stores Kafka metrics as time-series data
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
What happens when the retention period set for a Kafka topic expires?
Only messages older than the retention period are deleted.
The entire topic is deleted from the Kafka cluster.
Consumers can no longer subscribe to the topic.
The topic becomes read-only, preventing new messages from being published.
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
Key-based Partitioning
Round Robin Partitioning