Kafka Remanere | Fresco Play

Question 1: _________ has stronger ordering guarantees than a traditional messaging system.

Answer: kafka

Question 2: Which of the following is true regarding Zookeeper in Kafka?

Answer: All the options

Question 3: Communication between the clients and the servers is done with a simple, high-performance, language agnostic _________ protocol.

Answer: TCP

Question 4: __________ is the amount of time to keep a log segment before it is deleted.

Answer: log.retention

Question 5: If committed offset is larger than the offset of client processed last message, the messages between committed offset and last processed offset ____________.

Answer: will be missed

Question 6: Which of the following is true in Exactly-once message delivery semantics.

Answer: Chance of duplicates.

Question 7: What will happen to the record, if default partitioner is used in case of null key?

Answer: 1. Kafka will hash the key and use the result to map the message to a specific partition 2. Record will sent to partition where last message was sent.

Question 8: Point out the wrong statement.

Answer: All the options

Question 9: To distinguish compressed and uncompressed messages in Kafka, introduce a new property ____________ in the message header.

Answer: compression-attribute byte

Question 10: Which of the following is true regarding the message offset?

Answer: As a consumer of the message, you can get the offset from a Kafka broker

Question 11: Which of the following serializer do we need to use, when the object we send to Kafka is a simple String or Integer?

Answer: Default serializer

Question 12: Configure the ____________ by which consumer in Kafka will commit the largest offset the client received from Poll().

Answer: enable.auto.commit=true

Question 13: The time in which the stream-processing application received the event to perform some operations on data.

Answer: Processing time.

Question 14: ____________ parameter specifies the compression codec for all data generated by this producer.

Answer: compression.codec

Question 15: The main function of ____________ is to validate and direct the destination partition of the message.

Answer: partitioning key

Question 16: What will happen to the record, if default partitioner is used in case of key exists?

Answer: Kafka will hash the key and use the result to map the message to a specific partition

Question 17: Which of the following is the feature of Ktable?

Answer: continuously updated materialized view

Question 18: Kafka only provides a _________ order over messages within a partition.

Answer: total

Question 19: The information that is stored in between the events in Kafka is called __________.

Answer: STATE

Question 20: Which of the following is the capability of a streaming platform?

Answer: All the options

Question 21: Kafka is run as a cluster comprised of one or more servers each of which is called ___________.

Answer: broker

Question 22: Point out the correct statement.

Answer: Kafka is designed to allow a single cluster to serve as the central data backbone for a large organization.

Question 23: Each Kafka partition has one server which acts as the _________.

Answer: Leaders

Question 24: Kafka maintains feeds of messages in categories called ___________.

Answer: topics

Question 25: Point out the wrong statement.

Answer: The Kafka cluster does not retain all the published messages.

Question 26: In Kafka, ____________ will commit the latest offset returned by poll() and return once the offset is committed.

Answer: commitSync()

Question 27: Many people use Kafka as a replacement for a ___________ solution.

Answer: All the options

Question 28: Kafka uses key-value pairs in the ____________ file format for configuration.

Answer: Property

Question 29: In Kafka, the messages with the same key will go to the same ____________.

Answer: partition

Question 30: Which of the following is the feature of Kstream?

Answer: continuously updated materialized view

Question 31: The time at which the event arrived and stored to the Kafka broker is known as _________.

Answer: Log append time.

Question 32: __________ is the compression codecs supported in Kafka.

Answer: All the options

Question 33: Which of the following is the feature of Internal state in Kafka?

Answer: Is accessible only by a specific instance of the stream-processing application.

Question 34: Which of the following property can be used to change the time interval in Consumer commit in Kafka?

Answer: auto.commit.interval.ms

Question 35: Which of the following is the feature of External state in Kafka?

Answer: Is maintained in an external datastore, often a NOSQL system

Question 36: This parameter allows you to set whether compression should be turned on for particular topics.

Answer: compressed.topics

Question 37: Which of the following is true in At-most-once message delivery semantics?

Answer: Message pulled once

Question 38: Configure the `____________ by which consumer in Kafka will commit the current offset.

Answer: enable.auto.commit=false

Question 39: The time when the event occurred which we are tracking and the record was created is known as _________.

Answer: Event time.

Question 40: To commit an offset in Consumer, a message is produced to a special ____________ with the committed offset for each partition.

Answer: topic _consumer_offsets

Question 41: Point out the correct statement.

Answer: All the options

Question 42: If committed offset is smaller than the offset of client processed last message, the messages between committed offset and last processed offset ____________.

Answer: will be missed

Question 43: Which of the following is true in At-least-once message delivery semantics.

Answer: 1. May or may not be received. 2. Message pulled once.

Question 44: The action of updating the current offset position in a partition is defined as ____________.

Answer: commit

Question 45: Which of the following is true in Manual Commit in Kafka?

Answer: the application is blocked until the broker responds to the commit request.

Question 46: Point out the correct statement.

Answer: A topic is a category or feed name to which messages are published.

Question 47: Which of the following is true in Asynchronous Commit in Kafka?

Answer: Both the options