- Kafka is run as a cluster comprised of one or more servers called brokers. Each broker maintains feeds of messages in categories called topics.
- The only metadata retained on a per-consumer basis is the position of the consumer in the log, called offset.
- Each Kafka partition has one server which acts as the leader. The Kafka cluster does not retain all the published messages.
- Kafka is run as a cluster comprised of one or more servers called brokers. Each broker maintains feeds of messages in categories called topics.
- The only metadata retained on a per-consumer basis is the position of the consumer in the log, called offset.
- Each Kafka partition has one server which acts as the leader. The Kafka cluster does not retain all the published messages.
- Kafka is run as a cluster comprised of one or more servers called brokers. Each broker maintains feeds of messages in categories called topics.
- The only metadata retained on a per-consumer basis is the position of the consumer in the log, called offset.
- Each Kafka partition has one server which acts as the leader. The Kafka cluster does not retain all the published messages.
- Kafka is run as a cluster comprised of one or more servers called brokers. Each broker maintains feeds of messages in categories called topics.
- The only metadata retained on a per-consumer basis is the position of the consumer in the log, called offset.
- Each Kafka partition has one server which acts as the leader. The Kafka cluster does not retain all the published messages.
Download as XLSX, PDF, TXT or read online from Scribd
Download as xlsx, pdf, or txt
You are on page 1/ 7
Kafka is run as a cluster comprised of one or more servers each of which is called ___________.
*broker
The only metadata retained on a per-consumer basis is the position of the consumer in the log, called ________. *offset
Kafka maintains feeds of messages in categories called ___________.
*topics
Each Kafka partition has one server which acts as the _________. *leaders
Point out the wrong statement.
*The Kafka cluster does not retain all the published messages.
Which of the following is the feature of Kstream?
data as changelog stream continuously updated materialized view *append only
Many people use Kafka as a replacement for a ___________ solution.
compaction *log aggregation All the options collection
Communication between the clients and the servers is done with a simple, high-performance, language agnostic _________ p ICMP *TCP SMTP IP
Which of the following is the feature of External state in Kafka?
*Both the options Error Is accessible only by a specific instance of the stream-processing application. Is maintained in an external datastore, often a NOSQL system
In Kafka, ____________ will commit the latest offset returned by poll() and return once the offset is committed. *commitSync() enable.auto.commit=true enable.auto.commit=false auto.commit.interval.ms
Point out the wrong statement.
Kafka can serve as a kind of external commit-log for a distributed system. The log helps replicate data between nodes and acts as a re-syncing mechanism for failed nodes to restore their data. Kafka comes with a command line client that will take input from a file or from standard input and send it out as messages to *All the options
The time in which the stream-processing application received the event to perform some operations on data. Event time. *Processing time. og append time.
What will happen to the record, if default partitioner is used in case of key exists? *Record will sent to partition where last message was sent. Error Kafka will hash the key and use the result to map the message to a specific partition Record will be lost Record will sent randomly to one of available partitions.
This parameter allows you to set whether compression should be turned on for particular topics. compression.codec compression-attribute byte None of the options *compressed.topics
Which of the following is true in At-most-once message delivery semantics?
Receipt guaranteed No missing data *Message pulled once Chance of duplicates
Which of the following serializer do we need to use, when the object we send to Kafka is a simple String or Integer? Customer serializer Generic serialization library like Avro,Thrift *Default serializer
Which of the following is true in Asynchronous Commit in Kafka?
the application is blocked until the broker responds to the commit request. *instead of waiting for the broker to respond to a commit, just request will be sent and continue on. Both the options
_________ has stronger ordering guarantees than a traditional messaging system.
None of the options Slider Suz *kafka
Configure the `____________ by which consumer in Kafka will commit the current offset. *enable.auto.commit=false auto.commit.interval.ms topic _consumer_offsets enable.auto.commit=true
If committed offset is larger than the offset of client processed last message, the messages between committed offset and last will be processed exactly once will be processed once or many times. *will be missed will be processed twice
What will happen to the record, if default partitioner is used in case of null key? *Kafka will hash the key and use the result to map the message to a specific partition Error Record will sent to partition where last message was sent. Record will sent randomly to one of available partitions. Record will be lost
The time when the event occurred which we are tracking and the record was created is known as _________. Processing time. *Event time. Log append time.
Which of the following is true regarding Zookeeper in Kafka?
Zookeeper is basically used to communicate between different nodes in a cluster It is impossible to use Kafka without Zookeeper *All the options Once the Zookeeper is down, it cannot serve client request.
Which of the following is true in Exactly-once message delivery semantics.
Possible missing data. May or may not be received. *Message pulled one or more times;processed once. Chance of duplicates.
Which of the following is true in Manual Commit in Kafka?
*the application is blocked until the broker responds to the commit request. Both the options instead of waiting for the broker to respond to a commit, just request will be sent and continue on. d ________.
age agnostic _________ protocol.
committed. estore their data. end it out as messages to the Kafka cluster.
ring or Integer? committed offset and last processed offset ____________.
