Summer Goodies - 55% Discount Offer - Ends in 0d 00h 00m 00s - Coupon code: av5rz84q

Exact2Pass Menu

Question # 4

How will you find out all the partitions where one or more of the replicas for the partition are not in-sync with the leader?

A.

kafka-topics.sh --bootstrap-server localhost:9092 --describe --unavailable- partitions

B.

kafka-topics.sh --zookeeper localhost:2181 --describe --unavailable- partitions

C.

kafka-topics.sh --broker-list localhost:9092 --describe --under-replicated-partitions

D.

kafka-topics.sh --zookeeper localhost:2181 --describe --under-replicated-partitions

Full Access
Question # 5

How often is log compaction evaluated?

A.

Every time a new partition is created

B.

Every time a segment is closed

C.

Every time a message is sent to Kafka

D.

Every time a message is flushed to disk

Full Access
Question # 6

Which KSQL queries write to Kafka?

A.

COUNT and JOIN

B.

SHOW STREAMS and EXPLAIN statements

C.

CREATE STREAM WITH and CREATE TABLE WITH

D.

CREATE STREAM AS SELECT and CREATE TABLE AS SELECT

Full Access
Question # 7

What isn't a feature of the Confluent schema registry?

A.

Store avro data

B.

Enforce compatibility rules

C.

Store schemas

Full Access
Question # 8

A topic "sales" is being produced to in the Americas region. You are mirroring this topic using Mirror Maker to the European region. From there, you are only reading the topic for analytics purposes. What kind of mirroring is this?

A.

Passive-Passive

B.

Active-Active

C.

Active-Passive

Full Access
Question # 9

An ecommerce wesbite sells some custom made goods. What's the natural way of modeling this data in Kafka streams?

A.

Purchase as stream, Product as stream, Customer as stream

B.

Purchase as stream, Product as table, Customer as table

C.

Purchase as table, Product as table, Customer as table

D.

Purchase as stream, Product as table, Customer as stream

Full Access
Question # 10

Which actions will trigger partition rebalance for a consumer group? (select three)

A.

Increase partitions of a topic

B.

Remove a broker from the cluster

C.

Add a new consumer to consumer group

D.

A consumer in a consumer group shuts down

Add a broker to the cluster

Full Access
Question # 11

In Avro, adding an element to an enum without a default is a __ schema evolution

A.

breaking

B.

full

C.

backward

D.

forward

Full Access
Question # 12

The kafka-console-consumer CLI, when used with the default options

A.

uses a random group id

B.

always uses the same group id

C.

does not use a group id

Full Access
Question # 13

The Controller is a broker that is... (select two)

A.

elected by Zookeeper ensemble

B.

is responsible for partition leader election

C.

elected by broker majority

D.

is responsible for consumer group rebalances

Full Access
Question # 14

In the Kafka consumer metrics it is observed that fetch-rate is very high and each fetch is small. What steps will you take to increase throughput?

A.

Increase fetch.max.wait

B.

Increase fetch.max.bytes

C.

Decrease fetch.max.bytes

D.

Decrease fetch.min.bytes

E.

Increase fetch.min.bytes

Full Access
Question # 15

What is not a valid authentication mechanism in Kafka?

A.

SASL/GSSAPI

B.

SASL/SCRAM

C.

SAML

D.

SSL

Full Access
Question # 16

In Java, Avro SpecificRecords classes are

A.

automatically generated from an Avro Schema

B.

written manually by the programmer

C.

automatically generated from an Avro Schema + a Maven / Gradle Plugin

Full Access
Question # 17

A bank uses a Kafka cluster for credit card payments. What should be the value of the property unclean.leader.election.enable?

A.

FALSE

B.

TRUE

Full Access
Question # 18

How will you set the retention for the topic named “my-topic” to 1 hour?

A.

Set the broker config log.retention.ms to 3600000

B.

Set the consumer config retention.ms to 3600000

C.

Set the topic config retention.ms to 3600000

D.

Set the producer config retention.ms to 3600000

Full Access
Question # 19

A consumer sends a request to commit offset 2000. There is a temporary communication problem, so the broker never gets the request and therefore never responds. Meanwhile, the consumer processed another batch and successfully committed offset 3000. What should you do?

A.

Add a new consumer to the group

B.

Use the kafka-consumer-group command to manually commit the offsets 2000 for the consumer group

C.

Restart the consumer

D.

Nothing

Full Access
Question # 20

Compaction is enabled for a topic in Kafka by setting log.cleanup.policy=compact. What is true about log compaction?

A.

After cleanup, only one message per key is retained with the first value

B.

Each message stored in the topic is compressed

C.

Kafka automatically de-duplicates incoming messages based on key hashes

D.

After cleanup, only one message per key is retained with the latest value

Compaction changes the offset of messages

Full Access
Question # 21

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 record =

new ProducerRecord<>("topic1", "key1", "value1");

producer.send(record, new ProducerCallback());

A.

When the message is partitioned and batched successfully

B.

When message is serialized successfully

C.

When the broker response is received

D.

When send() method is called

Full Access
Question # 22

Once sent to a topic, a message can be modified

A.

No

B.

Yes

Full Access