Pass Confluent CCDAK Exam With Practice Test Questions Dumps Bundle [Q75-Q98]

NO.75 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?

3

5

2

1

NO.76 What are the requirements for a Kafka broker to connect to a Zookeeper ensemble? (select two)

Unique value for each broker’s zookeeper.connect parameter

Unique values for each broker’s broker.id parameter

All the brokers must share the same broker.id

All the brokers must share the same zookeeper.connect parameter

NO.77 How will you set the retention for the topic named my-topic to 1 hour?

Set the broker config log.retention.ms to 3600000

Set the consumer config retention.ms to 3600000

Set the topic config retention.ms to 3600000

Set the producer config retention.ms to 3600000

NO.78 A producer just sent a message to the leader broker for a topic partition. The producer used acks=1 and therefore the data has not yet been replicated to followers. Under which conditions will the consumer see the message?

Right away

When the message has been fully replicated to all replicas

Never, the produce request will fail

When the high watermark has advanced

NO.79 In Kafka, every broker… (select three)

contains all the topics and all the partitions

knows all the metadata for all topics and partitions

is a controller

knows the metadata for the topics and partitions it has on its disk

is a bootstrap broker

contains only a subset of the topics and the partitions

NO.80 A consumer starts and has auto.offset.reset=none, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 10 for the topic before. Where will the consumer read from?

offset 45

offset 10

it will crash

offset 2311

NO.81 Which KSQL queries write to Kafka?

COUNT and JOIN

SHOW STREAMS and EXPLAIN <query> statements

CREATE STREAM WITH <topic> and CREATE TABLE WITH <topic>

CREATE STREAM AS SELECT and CREATE TABLE AS SELECT

NO.82 Once sent to a topic, a message can be modified

No

Yes

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

2181

3888

443

2888

9092

80

NO.84 If I want to have an extremely high confidence that leaders and replicas have my data, I should use

acks=all, replication factor=2, min.insync.replicas=1

acks=1, replication factor=3, min.insync.replicas=2

acks=all, replication factor=3, min.insync.replicas=2

acks=all, replication factor=3, min.insync.replicas=1

NO.85 By default, which replica will be elected as a partition leader? (select two)

Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=true

Any of the replicas

Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=false

An in-sync replica

NO.86 There are 3 producers writing to a topic with 5 partitions. There are 10 consumers consuming from the topic as part of the same group. How many consumers will remain idle?

10

3

None

5

NO.87 Using the Confluent Schema Registry, where are Avro schema stored?

In the Schema Registry embedded SQL database

In the Zookeeper node /schemas

In the message bytes themselves

In the _schemas topic

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

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

Each message stored in the topic is compressed

Kafka automatically de-duplicates incoming messages based on key hashes

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

NO.89 Which of the following event processing application is stateless? (select two)

Read events from a stream and modifies them from JSON to Avro

Publish the top 10 stocks each day

Read log messages from a stream and writes ERROR events into a high-priority stream and the rest of the events into a low-priority stream

Find the minimum and maximum stock prices for each day of trading

NO.90 A customer has many consumer applications that process messages from a Kafka topic. Each consumer application can only process 50 MB/s. Your customer wants to achieve a target throughput of 1 GB/s. What is the minimum number of partitions will you suggest to the customer for that particular topic?

10

20

1

50

NO.91 What is true about partitions? (select two)

A broker can have a partition and its replica on its disk

You cannot have more partitions than the number of brokers in your cluster

A broker can have different partitions numbers for the same topic on its disk

Only out of sync replicas are replicas, the remaining partitions that are in sync are also leader

A partition has one replica that is a leader, while the other replicas are followers

NO.92 StreamsBuilder builder = new StreamsBuilder();
KStream<String, String> textLines = builder.stream(“word-count-input”); KTable<String, Long> wordCounts = textLines
.mapValues(textLine -> textLine.toLowerCase())
.flatMapValues(textLine -> Arrays.asList(textLine.split(“W+”)))
.selectKey((key, word) -> word)
.groupByKey()
.count(Materialized.as(“Counts”));
wordCounts.toStream().to(“word-count-output”, Produced.with(Serdes.String(), Serdes.Long())); builder.build(); What is an adequate topic configuration for the topic word-count-output?

max.message.bytes=10000000

cleanup.policy=delete

compression.type=lz4

cleanup.policy=compact

NO.93 How often is log compaction evaluated?

Every time a new partition is created

Every time a segment is closed

Every time a message is sent to Kafka

Every time a message is flushed to disk

NO.94 How do you create a topic named test with 3 partitions and 3 replicas using the Kafka CLI?

bin/kafka-topics.sh –create –broker-list localhost:9092 –replication-factor 3 –partitions 3 –topic test

bin/kafka-topics-create.sh –zookeeper localhost:9092 –replication-factor 3 –partitions 3 –topic test

bin/kafka-topics.sh –create –bootstrap-server localhost:9092 –replication-factor 3 –partitions 3 –topic test

bin/kafka-topics.sh –create –bootstrap-server localhost:2181 –replication-factor 3 –partitions 3 –topic test

NO.95 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?

Exactly-once

At-least-once

At-most-once

NO.96 Which of the following statements are true regarding the number of partitions of a topic?

The number of partitions in a topic cannot be altered

We can add partitions in a topic by adding a broker to the cluster

We can add partitions in a topic using the kafka-topics.sh command

We can remove partitions in a topic by removing a broker

We can remove partitions in a topic using the kafka-topics.sh command

NO.97 Consumer failed to process record # 10 and succeeded in processing record # 11. Select the course of action that you should choose to guarantee at least once processing

Commit offsets at 10

Do not commit until successfully processing the record #10

Commit offsets at 11

NO.98 To allow consumers in a group to resume at the previously committed offset, I need to set the proper value for…

value.deserializer

auto.offset.resets

group.id

enable.auto.commit

Leave a comment Cancel reply