Exam for engine

QUESTION 28
(You need to set alerts on key broker metrics to trigger notifications when a Kafka cluster is unhealthy.
What are three minimum broker metrics to monitor for cluster health?
Select three.)

QUESTION 29
If I produce to a topic that does not exist, and the broker setting auto.create.topic.enable=true, what will happen?

QUESTION 30
Match each configuration parameter with the correct deployment step in installing a Kafka connector.

QUESTION 31
In Java, Avro SpecificRecords classes are

QUESTION 32
If I want to send binary data through the REST proxy to topic “test_binary”, it needs to be base64 encoded. A consumer connecting directly into the Kafka topic

QUESTION 33
You are receiving orders from different customer in an “orders” topic with multiple partitions. Each message has the customer name as the key. There is a special customer named ABC that generates a lot of orders and you would like to reserve a partition exclusively for ABC. The rest of the message should be distributed among other partitions. How can this be achieved?

QUESTION 34
Where are the dynamic configurations for a topic stored?

QUESTION 35
What happens when broker.rack configuration is provided in broker configuration in Kafka cluster?

QUESTION 36
A consumer has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to
2311. The consumer group never committed offsets for the topic before. Where will the consumer read from?

QUESTION 37
In Kafka Streams, by what value are internal topics prefixed by?

QUESTION 38
You are using JDBC source connector to copy data from a table to Kafka topic. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many tasks are launched?

QUESTION 39
is KSQL ANSI SQL compliant?

QUESTION 40
Your company has three Kafka clusters: Development, Testing, and Production.
The Production cluster is running out of storage, so you add a new node.
Which two statements about the new node are true?
(Select two.)

QUESTION 41
Match each configuration parameter with the correct deployment step in installing a Kafka connector.

QUESTION 42
To get acknowledgement of writes to only the leader partition, we need to use the config…

QUESTION 43
Match the testing tool with the type of test it is typically used to perform.

QUESTION 44
There are 3 producers writing to a topic with 5 partitions. There are 5 consumers consuming from the topic. How many Controllers will be present in the cluster?

QUESTION 45
A Zookeeper ensemble contains 3 servers. Over which ports the members of the ensemble should be able to communicate in default configuration? (select three)

QUESTION 46
This schema excerpt is an example of which schema format?
package com.mycorp.mynamespace;
message SampleRecord {
int32 Stock = 1;
double Price = 2;
string Product_Name = 3;
}

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

QUESTION 48
What is the disadvantage of request/response communication?

QUESTION 49
When is the onCompletion() method called?
private class ProducerCallback implements Callback {
@Override
public void onCompletion(RecordMetadata recordMetadata, Exception e) {
if (e != null) {
e.printStackTrace();
}
}
}
ProducerRecord<String, String> record =
new ProducerRecord<>(“topic1”, “key1”, “value1”);
producer.send(record, new ProducerCallback());