Question 1

We have a store selling shoes. What dataset is a great candidate to be modeled as a KTable in Kafka Streams?

Options :

A : Money made until now

B : The transaction stream

C : Items returned

D : Inventory contents right now

Answer: A,C

Question 2

while (true) {
ConsumerRecords< String, String > records = consumer.poll(100);
try {
consumer.commitSync();
} catch (CommitFailedException e) {
log.error('commit failed', e)
}
for (ConsumerRecord< String, String > record records)
{
System.out.printf('topic = %s, partition = %s, offset =
%d, customer = %s, country = %s
',
record.topic(), record.partition(),
record.offset(), record.key(), record.value());
}
}
What kind of delivery guarantee this consumer offers?

Options :

A : Exactly-once

B : At-least-once

C : At-most-once

Answer: C

Question 3

What is the default port that the KSQL server listens on?

Options :

A : 9092

B : 8088

C : 8083

D : 2181

Answer: B

Question 4

Where does Kafka store Consumer offsets?

Options :

A : Controller

B : Zookeeper

C : System topic

D : User topic

Answer: C

Question 5

Which of the following best describes Kafka Connect

Options :

A : Kafka Connect is a framework for streaming data between Apache Kafka and other data systems

B : Kafka Connect is a centralized service for maintaining configuration information, naming, providing distributed synchronization, and providing group services.

C : Kafka Connect provides a RESTful interface to a Kafka cluster, making it easy to produce and consume messages, view the state of the cluster, and perform administrative actions without using the native Kafka protocol or clients

D : Kafka Connect provides a serving layer for your metadata. It provides a RESTful interface for storing and retrieving Avro schemas. It stores a versioned history of all schemas, provides multiple compatibility settings and allows evolution of schemas according to the configured compatibility settings and expanded Avro support.

Answer: A