CCDAK | A Review Of Simulation CCDAK Free Download

NEW QUESTION 1
How does a consumer commit offsets in Kafka?

• A. It directly sends a message to the consumer_offsets topic
• B. It interacts with the Group Coordinator broker
• C. It directly commits the offsets in Zookeeper

Answer: B

Explanation:
Consumers do not directly write to the consumer_offsets topic, they instead interact with a broker that has been elected to manage that topic, which is the Group Coordinator broker

NEW QUESTION 2
You want to perform table lookups against a KTable everytime a new record is received from the KStream. What is the output of KStream-KTable join?

• A. KTable
• B. GlobalKTable
• C. You choose between KStream or KTable
• D. Kstream

Answer: D

Explanation:
Here KStream is being processed to create another KStream.

NEW QUESTION 3
An ecommerce website maintains two topics - a high volume "purchase" topic with 5 partitions and low volume "customer" topic with 3 partitions. You would like to do a stream- table join of these topics. How should you proceed?

• A. Repartition the purchase topic to have 3 partitions
• B. Repartition customer topic to have 5 partitions
• C. Model customer as a GlobalKTable
• D. Do a KStream / KTable join after a repartition step

Answer: C

Explanation:
In case of KStream-KStream join, both need to be co-partitioned. This restriction is not applicable in case of join with GlobalKTable, which is the most efficient here.

NEW QUESTION 4
How will you find out all the partitions without a leader?

• A. kafka-topics.sh --broker-list localhost:9092 --describe --under-replicated-partitions
• B. kafka-topics.sh --bootstrap-server localhost:2181 --describe --unavailable-partitions
• C. kafka-topics.sh --zookeeper localhost:2181 --describe --unavailable-partitions
• D. kafka-topics.sh --zookeeper localhost:2181 --describe --under-replicated-partitions

Answer: C

Explanation:
Please note that as of Kafka 2.2, the --zookeeper option is deprecated and you can now usekafka-topics.sh --bootstrap-server localhost:9092 --describe --unavailable-partitions

NEW QUESTION 5
To read data from a topic, the following configuration is needed for the consumers

• A. all brokers of the cluster, and the topic name
• B. any broker to connect to, and the topic name
• C. the list of brokers that have the data, the topic name and the partitions list
• D. any broker, and the list of topic partitions

Answer: B

Explanation:
All brokers can respond to Metadata request, so a client can connect to any broker in the cluster.

NEW QUESTION 6
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?

• A. 10
• B. 20
• C. 1
• D. 50

Answer: B

Explanation:
each consumer can process only 50 MB/s, so we need at least 20 consumers consuming one partition so that 50 * 20 = 1000 MB target is achieved.

NEW QUESTION 7
When using plain JSON data with Connect, you see the following error messageorg.apache.kafka.connect.errors.DataExceptionJsonDeserializer with schemas.enable requires "schema" and "payload" fields and may not contain additional fields. How will you fix the error?

• A. Set key.converter, value.converter to JsonConverter and the schema registry url
• B. Use Single Message Transforms to add schema and payload fields in the message
• C. Set key.converter.schemas.enable and value.converter.schemas.enable to false
• D. Set key.converter, value.converter to AvroConverter and the schema registry url

Answer: C

Explanation:
You will need to set the schemas.enable parameters for the converter to false for plain text with no schema.

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

• A. 9092
• B. 8088
• C. 8083
• D. 2181

Answer: B

Explanation:
Default port of KSQL server is 8088

NEW QUESTION 9
A Zookeeper ensemble contains 5 servers. What is the maximum number of servers that can go missing and the ensemble still run?

• A. 3
• B. 4
• C. 2
• D. 1

Answer: C

Explanation:
majority consists of 3 zk nodes for 5 nodes zk cluster, so 2 can fail

NEW QUESTION 10
Select all that applies (select THREE)

• A. min.insync.replicas is a producer setting
• B. acks is a topic setting
• C. acks is a producer setting
• D. min.insync.replicas is a topic setting
• E. min.insync.replicas matters regardless of the values of acks
• F. min.insync.replicas only matters if acks=all

Answer: CDF

Explanation:
acks is a producer setting min.insync.replicas is a topic or broker setting and is only effective when acks=all

NEW QUESTION 11
By default, which replica will be elected as a partition leader? (select two)

• A. Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=true
• B. Any of the replicas
• C. Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=false
• D. An in-sync replica

Answer: BD

Explanation:
Preferred leader is a broker that was leader when topic was created. It is preferred because when partitions are first created, the leaders are balanced between brokers. Otherwise, any of the in-sync replicas (ISR) will be elected leader, as long as unclean.leader.election=false (by default)

NEW QUESTION 12
Which of these joins does not require input topics to be sharing the same number of partitions?

• A. KStream-KTable join
• B. KStream-KStream join
• C. KStream-GlobalKTable
• D. KTable-KTable join

Answer: C

Explanation:
GlobalKTables have their datasets replicated on each Kafka Streams instance and therefore no repartitioning is required

NEW QUESTION 13
Which of the following event processing application is stateless? (select two)

• A. Read events from a stream and modifies them from JSON to Avro
• B. Publish the top 10 stocks each day
• C. 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
• D. Find the minimum and maximum stock prices for each day of trading

Answer: AC

Explanation:
Stateless means processing of each message depends only on the message, so converting from JSON to Avro or filtering a stream are both stateless operations

NEW QUESTION 14
Select the Kafka Streams joins that are always windowed joins.

• A. KStream-KStream join
• B. KTable-KTable join
• C. KStream-GlobalKTable
• D. KStream-KTable join

Answer: A

Explanation:
Seehttps://docs.confluent.io/current/streams/developer-guide/dsl-api.html#joining

NEW QUESTION 15
A kafka topic has a replication factor of 3 and min.insync.replicas setting of 2. How many brokers can go down before a producer with acks=all can't produce?

• A. 2
• B. 1
• C. 3

Answer: C

Explanation:
acks=all and min.insync.replicas=2 means we must have at least 2 brokers up for the partition to be available

NEW QUESTION 16
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

Answer: AB

Explanation:
Controller is a broker that in addition to usual broker functions is responsible for partition leader election. The election of that broker happens thanks to Zookeeper and at any time only one broker can be a controller

NEW QUESTION 17
......