CCDAK Apache Kafka Practice Test

These questions are part of the practice quiz. Start practicing

• Publishing data from Kafka to a common data source (exporting data to an external database) is called what?
• What is a major architectural change when moving from ZooKeeper-based clusters to KRaft?
• Which window type is time-based, fixed size, with overlapping windows?
• Which port is used by KSQL by default?
• In the database table analogy, a KStream record is interpreted as an INSERT statement.
• Setting auto.offset.reset=latest causes the consumer to read from?
• What is the default value of auto.commit.interval.ms?
• What is log compaction in Kafka, and when is it useful?
• Which Kafka metric indicates lagging replicas in a cluster?
• If you configure very small segment.ms values, what is a likely consequence?
• Which of the following errors is retriable from the Kafka Producer?
• In Confluent Schema Registry, which topic stores the Avro schemas?
• How do max.message.bytes and message.max.bytes constrain record size, and what should you align across broker and client configurations?
• What is the join type for KTable-to-KTable joins?
• Which join scenario allows joining a topic with 5 partitions to a topic with 3 partitions without co-partitioning?
• Which description best matches KStream-to-KTable join characteristics?
• In a Tumbling Window with window-size 5 minutes and advance-interval 5 minutes, which window sequence is produced?
• In Avro schema evolution, adding a field to a record without a default value is considered which type?
• What does fetch.message.max.bytes configure?
• Which statement correctly describes exactly-once semantics and how to enable it in Kafka?
• How do you describe the details of a topic named 'my-first-topic'?
• Which command starts consuming messages from a topic starting from the beginning?
• Where are quotas configured in a Kafka cluster to protect multi-tenant environments?
• What is a key security difference between SCRAM-SHA-256 and SASL/PLAIN in Kafka?
• Which port is used by the Schema Registry by default?
• What is the default value for max.poll.interval.ms?
• In a ZooKeeper multi-node configuration, with tickTime=2000 and initLimit=5, what is the time in milliseconds required to initialize a follower with the current leader?
• According to recommended practice, before producing new events with a new schema, you should upgrade which?
• What is the default size of a Kafka message?
• What is records-lag-max?
• If replication.factor=2 and min.insync.replicas=2, what happens when one replica goes down or falls out of sync?
• NONE compatibility means which of the following?
• By default, how is the target partition chosen for a record with a key in Kafka?
• Which Java library is KSQL based on?
• How do SASL authentication and TLS encryption protect Kafka cluster communications, and what configuration options are typically used?
• To publish a 15 MB message, you must configure which broker/topic setting?
• For KStream-to-KTable joins, what are the output type, windowing, co-partitioning, and join type?
• Which of the following is NOT a Kafka producer property?
• Which statement best describes the primary role of Kafka Connect in data integration?
• To process all messages from a 4-partition topic with two applications, the optimal setup is to create two consumer groups with four consumers in each group.
• In a single consumer group, each consumer is assigned to what type of partition?
• FULL compatibility means backward and forward compatibility between which schemas?
• Which statement about the KTable's database table analogy is true?
• Which statement about high watermark is true?
• Which setting controls how many records to receive per poll request?
• In a ZooKeeper-based Kafka cluster, what type of metadata resides in ZooKeeper, and where is this metadata stored under KRaft?
• Which command deletes a Kafka topic named 'my-first-topic'?
• What is the practical effect of setting max.in.flight.requests.per.connection low in a transactional producer?
• Which command would you use to list all topics without describing them?
• What is the difference between Kafka Connect running in standalone mode versus distributed mode, and when would you choose each?
• Keys are hashed using which algorithm by default?
• What is a major change with KRaft in terms of ZooKeeper usage?
• What is the purpose of a changelog topic in Kafka Streams?
• In Confluent Schema Registry, what does a compatibility level of FULL ensure?
• Which schema evolution category applies when a field with a default value is added or removed in Avro?
• Which combination uniquely identifies a consumed message in Kafka?
• Which command lists all Kafka topics using Zookeeper?
• Which authentication mechanism is Kerberos-based in Kafka?
• Which AdminClient operation would you use to provision topics programmatically?
• Which command shows partitions without a leader for a topic?
• When a member joins or leaves a Kafka consumer group, what happens to the partition assignments?
• Which mechanism is used to detect if a consumer application has died?
• What is a state store in Kafka Streams, and how does a changelog topic support fault tolerance?
• Which of the following is an Avro primitive type?
• What is the output type when performing a KStream-to-GlobalKTable join?
• What is the purpose of the transactional.id in Kafka producers?
• Which broker setting controls the retention period for consumer offsets when no new data is read for a period (for example seven days)?
• Deleting a field without a default value in an Avro schema is which type of compatibility?
• Why is a transactional.id required for transactional producers, and what can happen if a transaction is not properly aborted on error?
• With tickTime=2000 and syncLimit=2, what is the maximum time in milliseconds that a follower can be out of sync with the leader?
• Which statement about high watermark is false?
• Which window type is dynamic, non-overlapping, and data-driven for aggregating key-based events into a session?
• Which command shifts offsets by 2 positions backward for a consumer group on a topic?
• Distinguish between the Kafka Streams API and ksqlDB in terms of programming model and typical use cases.
• Which command describes a consumer group named 'my-first-consumer-group'?
• When creating a topic with AdminClient, which arguments specify partitions and replication factor?
• How do batch.size, linger.ms, and max.in.flight.requests.per.connection affect producer throughput and message ordering guarantees?
• How do Kafka Access Control Lists (ACLs) regulate operations, and what are common patterns for producers and consumers?
• Is co-partitioning required for KStream-to-GlobalKTable joins?
• If a key is sent, do all messages for that key go to the same partition?
• Which control ensures consumers do not read unreplicated data?
• How do producer retries interact with idempotence and transactions to ensure reliable delivery under transient failures?
• Which command resets a consumer group's offsets to the earliest offset for a specific topic?
• Which statement about the high watermark is correct?
• In Avro schema evolution, removing or adding a field that has a default value is classified as which type?
• Which of the following is NOT a mandatory producer property?
• Which of the following is NOT a complex type in Avro schema definitions?
• With 10 consumers and 5 partitions, how many consumers will have partitions assigned?
• What is the correct format for a ZooKeeper ensemble member's server configuration line?
• With 5 consumers and 10 partitions, how many partitions per consumer and is any consumer idle?
• Which flag ensures the producer waits for all in-sync replicas to acknowledge messages?
• In an e-commerce application, any type of transactions like purchase or payment should be modeled as KStream.
• Which producer property is not among the mandatory ones listed for producer configuration?
• Can an older Kafka client (1.1) talk to a newer broker (2.0) and can a newer client (2.0) talk to an older broker (1.1)?
• Setting auto.offset.reset=none causes what happens if no offset is found?
• Which capability does MirrorMaker 2 provide to manage replication across clusters?
• How do Kafka transactions enable exactly-once semantics for producers, and what are the key steps to use them?
• When is data sent in round robin?
• Segment bytes and segment.ms influence log rolling; what is the effect on retention and compaction?
• Which setting controls how much data you want to pull at least on each request?
• FULL compatibility means backward and forward compatibility between which schemas?
• What is the primary function of the Kafka Consumer?
• Which compatibility mode in Schema Registry ensures that a new schema can read data written with an older schema, while preserving producer/consumer evolution decisions?
• What is the difference between automatic offset commits and manual commits in a Kafka consumer, and when would you choose each?
• Getting data from a common data source to Kafka (for example importing data from an external database) is called what?
• Which command starts consuming messages in a consumer group named 'my-first-consumer-group'?
• Setting auto.offset.reset=earliest causes the consumer to read from?
• How does replication.factor influence fault tolerance and load in a Kafka cluster?
• Which AdminClient operation would you use to inspect the configuration of a topic?
• To transform data from a Kafka topic to another, you should use which of the following?
• Which command is used to produce messages to a Kafka topic named 'my-first-topic'?
• In Schema Registry, which compatibility mode ensures that data written with older schemas can be read by consumers using newer schemas?
• Which command creates a Kafka topic named 'my-first-topic' with 3 partitions and replication factor 3 using ZooKeeper?
• Which setting defines the maximum data returned by the broker per partition?
• Which statement correctly describes keys and partition assignment?
• Compare Avro, JSON, and Protobuf in terms of schema evolution and payload efficiency in Kafka.
• What is the command to start a Kafka server with the default server properties?
• Which error is thrown if you send a message larger than the default maximum size?
• Which command lists all consumer groups?
• Which of the following is NOT a stateless operator in Kafka Streams?
• Which statement about a Hopping Window is true?
• FORWARD compatibility could be defined as which statement?
• Which command resets a consumer group's committed offset to an earlier point?
• If a consumer hasn't read new data for 7 days, which broker setting controls the retention of its offset?
• How does MirrorMaker 2 handle offset alignment and idempotence during failover between clusters?
• Which property is used to specify where to connect for a Kafka producer?
• In a transactional workflow, which consumer setting ensures you only see committed transactions?
• Per thread how many consumers are allowed, and can the consumer be multi-threaded?
• You want to sink data from a Kafka topic to S3 using Kafka Connect. There are 10 brokers in the cluster, the topic has 2 partitions with replication factor of 3. How many tasks will you configure for the S3 connector?
• Which port is used by followers to connect to the active leader?
• Which of the following is a stateful Kafka Streams operator?
• If there are more partitions than consumers in a group, what could happen?
• Which of the following is NOT listed as a SerDes data type for Kafka Streams?
• Which statement best describes KRaft mode in Kafka compared to ZooKeeper-based architecture?
• Kafka is best described as which type of messaging system? (variant wording to test understanding)
• Which factors are important when sizing Kafka brokers and storage for cloud deployments?
• Which statement best describes the relationship between backward, forward, and full compatibility in schema evolution?
• Which AdminClient operation would you use to remove a topic when retiring it?
• What is the purpose of a source connector vs a sink connector in Kafka Connect, and provide an example of each.
• Which description correctly outlines an end-to-end Kafka data pipeline using Avro schemas with Schema Registry, including producer, topic, schema, and consumers; highlight recovery steps?
• What mitigations help Kafka survive controller failover and broker outages?
• How is the myid value set for a ZooKeeper ensemble member?
• Kafka is mostly written in which programming language?
• What does the read_committed isolation level ensure in Kafka consumers?
• What is the relationship between the committed offset and the consumer's current position?
• Which properties are mandatory to configure a Kafka producer?
• To tolerate the loss of two ZooKeeper servers, what is the minimum total number of servers in the ensemble?
• Which practice is essential for managing schema evolution?
• Which statement about the Consumer assign() method is correct?
• Which data formats are supported by the Confluent Schema Registry?
• Which architectural component is eliminated in KRaft mode compared to ZooKeeper-based Kafka?
• Is KSQL ANSI SQL compliant?
• What contains the offset of the last message copied to all replicas?
• Which of the following is a complex type in Avro?
• Where are consumer offsets stored in modern Kafka versions?
• GlobalKTable is an abstraction of the changelog stream from which partitions?
• Which port is the Kafka Broker listening on by default?
• Which command shifts offsets by 2 positions forward for a consumer group on a topic?
• Which metric shows whether a Kafka cluster has an active controller?
• Which statement accurately describes the KTable's relation to the changelog stream?
• What is the default value for session.timeout.ms?
• What is the ZooKeeper address format used in these Kafka command examples?
• What is the equation for the ZooKeeper ensemble size required to tolerate n faults?
• How would you replay data from an old offset for a consumer group, and what risks does this pose?
• Which window type is fixed-size, overlapping, and used only for JOIN operations?
• Which property controls the interval at which Kafka auto-commits offsets?
• Which of the following best describes the high watermark's role?
• For KTable-to-KTable joins, what is the output type, co-partitioning, and join type?
• Which setting enables manual control of offset commits?
• What is the default value of fetch.min.bytes?
• Which AdminClient operation would you use to create a topic with 3 partitions and replication factor 2, and what code would look like?
• What does isolation.level=read_committed do in a Kafka consumer, and when would you enable it?
• For KStream-to-GlobalKTable joins, what are the output type, windowing, co-partitioning, and join type?
• Is it recommended to disable auto-commit and manually commit offsets?
• Does increasing the number of partitions affect the guarantee that all messages with the same key go to the same partition?
• What is the default Confluent Schema Registry compatibility type?
• Which framework is used to transform data from one Kafka topic to another?
• What is the difference between acks=all and acks=1 in Kafka producers?
• What is the purpose of the initTransactions step in Kafka producer transactions?
• Which setting defines the maximum data returned for each fetch request (covers multiple partitions)?
• Which command demonstrates consuming messages from a topic as a specific group and from the beginning?
• How do retention.ms and log.cleanup.policy affect data retention and log segment behavior in Kafka topics?
• Which client protocols are supported by the Confluent Schema Registry?
• What are the steps to integrate Kafka with Kerberos authentication, and what common pitfalls should you avoid?
• In an e-commerce application, which data should be modeled as a KTable?
• Which command shows the replication factor and partition count for a topic named 'my-first-topic'?
• Which statement about high watermark is accurate?
• What is the generic unique identifier that can be used for a message received from a consumer?
• In an Avro field definition, which element is required?
• What is recommended before you start producing new events when schemas change?
• Which combination identifies a specific record in Kafka by topic, partition, and offset?
• What is the role of the Confluent Schema Registry in a Kafka ecosystem, and how does it enforce compatibility?
• Which feature must be used to achieve exactly-once semantics on the producer side?
• Does adding a partition to a topic lose the guarantee that the same key goes to the same partition?
• In Kafka Streams, what is the role of a changelog-backed state store?
• What is the default value for heartbeat.interval.ms?
• What is consumer lag, how is it calculated, and why is it important for service level agreements?
• How does the high watermark bound a consumer's reads?
• How would you enforce per-topic retention policies for different data categories?
• Kafka is best described as which type of messaging system?
• Which of the following is a common failure scenario in a Kafka deployment and its recommended mitigation?
• If enable.auto.commit is false, what must you do to commit offsets?
• What is a key trade-off of using Avro with Schema Registry?
• Can a Producer send a key with a message?
• For a KStream-to-KStream join, what are the output type, whether it's windowed, co-partitioning requirement, and the join type?
• What is the command to start a ZooKeeper server with the default configuration file?
• Which configuration controls how a consumer starts reading when there is no committed offset?
• If enable.auto.commit is true and you do not use synchronous processing, what offset commit semantics do you get?
• Which statement about gzip, snappy, and lz4 is true, and when would you pick each?
• Which window type is time-based, fixed size, non-overlapping, and gapless?
• How does Kafka Streams implement exactly-once semantics for stateful computations, and what features support this?
• In Kafka, if the current leader broker fails and there are in-sync replicas (ISRs), what happens to the partition?
• Which statement about co-partitioning requirements for KStream-to-GlobalKTable joins is true?
• Which statement about min.insync.replicas best describes its effect on write durability if a broker goes down?
• What does an increasing records-lag-max indicate?
• In a three-node ZooKeeper ensemble, the typical myid values assigned to each member are 1, 2, and 3.
• What is the purpose of enabling enable.idempotence on a Kafka producer, and what constraint does it impose on acks and in-flight requests?
• What does co-partition mean in Kafka Streams joins?
• What is MirrorMaker 2, and how does it help with disaster recovery or cross-region data replication in Kafka?
• What is retry.backoff.ms?
• The KStream abstraction represents a record stream from a subset of partitions of a topic.
• If a topic uses cleanup.policy=compact and retention.ms is configured, how do compaction and retention interact?