Best Quality Confluent CCDAK Exam Questions TestBraindump Realistic Practice Exams [2022]
Critical Information To Confluent Certified Developer for Apache Kafka Certification Examination Pass the First Time
NEW QUESTION 79
Which of these joins does not require input topics to be sharing the same number of partitions?
- A. KStream-GlobalKTable
- B. KTable-KTable join
- C. KStream-KStream join
- D. KStream-KTable join
Answer: A
Explanation:
GlobalKTables have their datasets replicated on each Kafka Streams instance and therefore no repartitioning is required
NEW QUESTION 80
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. Active-Passive
- B. Passive-Passive
- C. Active-Active
Answer: A
Explanation:
This is active-passing as the replicated topic is used for read-only purposes only
NEW QUESTION 81
The Controller is a broker that is... (select two)
- A. is responsible for partition leader election
- B. elected by Zookeeper ensemble
- C. elected by broker majority
- D. is responsible for consumer group rebalances
Answer: A,B
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 82
Suppose you have 6 brokers and you decide to create a topic with 10 partitions and a replication factor of 3. The brokers 0 and 1 are on rack A, the brokers 2 and 3 are on rack B, and the brokers 4 and 5 are on rack C.
If the leader for partition 0 is on broker 4, and the first replica is on broker 2, which broker can host the last replica? (select two)
- A. 0
- B. 1
- C. 2
- D. 3
- E. 4
- F. 5
Answer: B,E
Explanation:
When you create a new topic, partitions replicas are spreads across racks to maintain availability. Hence, the Rack A, which currently does not hold the topic partition, will be selected for the last replica
NEW QUESTION 83
Which of the following setting increases the chance of batching for a Kafka Producer?
- A. Increase the number of producer threads
- B. Increase linger.ms
- C. Increase batch.size
- D. Increase message.max.bytes
Answer: B
Explanation:
linger.ms forces the producer to wait to send messages, hence increasing the chance of creating batches
NEW QUESTION 84
What's is true about Kafka brokers and clients from version 0.10.2 onwards?
- A. Clients and brokers must have the exact same version to be able to communicate
- B. A newer client can talk to a newer broker, and an older client can talk to a newer broker
- C. A newer client can't talk to a newer broker, but an older client can talk to a newer broker
- D. A newer client can talk to a newer broker, but an older client cannot talk to a newer broker
Answer: B
Explanation:
Kafka's new bidirectional client compatibility introduced in 0.10.2 allows this. Read more herehttps://www.confluent.io/blog/upgrading-apache-kafka-clients-just-got-easier/
NEW QUESTION 85
If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?
- A. Zero copy
- B. Exactly-once delivery
- C. Cross-cluster mirroring
- D. Support for Avro format
Answer: A
Explanation:
With SSL, messages will need to be encrypted and decrypted, by being first loaded into the JVM, so you lose the zero copy optimization. See more information herehttps://twitter.com/ijuma/status/1161303431501324293?s=09
NEW QUESTION 86
Your manager would like to have topic availability over consistency. Which setting do you need to change in order to enable that?
- A. compression.type
- B. unclean.leader.election.enable
- C. min.insync.replicas
Answer: B
Explanation:
unclean.leader.election.enable=true allows non ISR replicas to become leader, ensuring availability but losing consistency as data loss will occur
NEW QUESTION 87
You want to sink data from a Kafka topic to S3 using Kafka Connect. There are 10 brokers in the cluster, the topic has 2 partitions with replication factor of 3. How many tasks will you configure for the S3 connector?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: C
Explanation:
You cannot have more sink tasks (= consumers) than the number of partitions, so 2.
NEW QUESTION 88
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.min.bytes
- B. Decrease fetch.min.bytes
- C. Increase fetch.max.bytes
- D. Increase fetch.max.wait
- E. Decrease fetch.max.bytes
Answer: A
Explanation:
This will allow consumers to wait and receive more bytes in each fetch request.
NEW QUESTION 89
What happens when broker.rack configuration is provided in broker configuration in Kafka cluster?
- A. Replicas for a partition are spread across different racks
- B. Replicas for a partition are placed in the same rack
- C. You can use the same broker.id as long as they have different broker.rack configuration
- D. Each rack contains all the topics and partitions, effectively making Kafka highly available
Answer: A
Explanation:
Partitions for newly created topics are assigned in a rack alternating manner, this is the only change broker.rack does
NEW QUESTION 90
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
Answer: A
Explanation:
Setting unclean.leader.election.enable to true means we allow out-of-sync replicas to become leaders, we will lose messages when this occurs, effectively losing credit card payments and making our customers very angry.
NEW QUESTION 91
What is a generic unique id that I can use for messages I receive from a consumer?
- A. topic + partition + timestamp
- B. topic + partition + offset
- C. topic + timestamp
Answer: B
Explanation:
(Topic,Partition,Offset) uniquely identifies a message in Kafka
NEW QUESTION 92
If I want to have an extremely high confidence that leaders and replicas have my data, I should use
- A. acks=1, replication factor=3, min.insync.replicas=2
- B. acks=all, replication factor=3, min.insync.replicas=2
- C. acks=all, replication factor=3, min.insync.replicas=1
- D. acks=all, replication factor=2, min.insync.replicas=1
Answer: B
Explanation:
acks=all means the leader will wait for all in-sync replicas to acknowledge the record. Also the min in-sync replica setting specifies the minimum number of replicas that need to be in-sync for the partition to remain available for writes.
NEW QUESTION 93
Your producer is producing at a very high rate and the batches are completely full each time. How can you improve the producer throughput? (select two)
- A. Increase batch.size
- B. Enable compression
- C. Decrease linger.ms
- D. Disable compression
- E. Decrease batch.size
Answer: A,B
Explanation:
Increase linger.ms
Explanation:
batch.size controls how many bytes of data to collect before sending messages to the Kafka broker. Set this as high as possible, without exceeding available memory. Enabling compression can also help make more compact batches and increase the throughput of your producer. Linger.ms will have no effect as the batches are already full
NEW QUESTION 94
A Zookeeper configuration has tickTime of 2000, initLimit of 20 and syncLimit of 5. What's the timeout value for followers to connect to Zookeeper?
- A. 20 sec
- B. 2000 ms
- C. 10 sec
- D. 40 sec
Answer: D
Explanation:
tick time is 2000 ms, and initLimit is the config taken into account when establishing a connection to Zookeeper, so the answer is 2000 * 20 = 40000 ms = 40s
NEW QUESTION 95
What isn't an internal Kafka Connect topic?
- A. connect-configs
- B. connect-jars
- C. connect-status
- D. connect-offsets
Answer: B
Explanation:
connect-configs stores configurations, connect-status helps to elect leaders for connect, and connect-offsets store source offsets for source connectors
NEW QUESTION 96
Your streams application is reading from an input topic that has 5 partitions. You run 5 instances of your application, each with num.streams.threads set to 5. How many stream tasks will be created and how many will be active?
- A. 5 created, 5 active
- B. 5 created, 1 active
- C. 25 created, 5 active
- D. 25 created, 25 active
Answer: C
Explanation:
One partition is assigned a thread, so only 5 will be active, and 25 threads (i.e. tasks) will be created
NEW QUESTION 97
Select all that applies (select THREE)
- A. min.insync.replicas is a producer setting
- B. acks is a producer setting
- C. min.insync.replicas is a topic setting
- D. min.insync.replicas only matters if acks=all
- E. acks is a topic setting
- F. min.insync.replicas matters regardless of the values of acks
Answer: B,C,D
Explanation:
acks is a producer setting min.insync.replicas is a topic or broker setting and is only effective when acks=all
NEW QUESTION 98
What is returned by a producer.send() call in the Java API?
- A. Future<ProducerRecord> object
- B. A Boolean indicating if the call succeeded
- C. Future<RecordMetadata> object
- D. Unit
Answer: C
Explanation:
Seehttps://kafka.apache.org/21/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html
NEW QUESTION 99
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
- A. base64 encoded data, it will need to decode it
- B. "test_binary" will receive
- C. json data
- D. binary data
- E. avro data
Answer: D
Explanation:
On the producer side, after receiving base64 data, the REST Proxy will convert it into bytes and then send that bytes payload to Kafka. Therefore consumers reading directly from Kafka will receive binary data.
NEW QUESTION 100
Producing with a key allows to...
- A. Ensure per-record level security
- B. Add more information to my message
- C. Allow a Kafka Consumer to subscribe to a (topic,key) pair and only receive that data
- D. Influence partitioning of the producer messages
Answer: D
Explanation:
Keys are necessary if you require strong ordering or grouping for messages that share the same key. If you require that messages with the same key are always seen in the correct order, attaching a key to messages will ensure messages with the same key always go to the same partition in a topic. Kafka guarantees order within a partition, but not across partitions in a topic, so alternatively not providing a key - which will result in round-robin distribution across partitions - will not maintain such order.
NEW QUESTION 101
What is the default port that the KSQL server listens on?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: A
Explanation:
Default port of KSQL server is 8088
NEW QUESTION 102
What data format isn't natively available with the Confluent REST Proxy?
- A. binary
- B. protobuf
- C. json
- D. avro
Answer: B
Explanation:
Protocol buffers isn't a natively supported type for the Confluent REST Proxy, but you may use the binary format instead
NEW QUESTION 103
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. Restart the consumer
- B. Use the kafka-consumer-group command to manually commit the offsets 2000 for the consumer group
- C. Add a new consumer to the group
- D. Nothing
Answer: D
Explanation:
In this case, because the offset 3000 has been committed and all the messages between 0 and 3000 have all been processed, it is okay not to have committed offset 2000. The right answer is to do "nothing", this behaviour is acceptable
NEW QUESTION 104
......
CCDAK EXAM DUMPS WITH GUARANTEED SUCCESS: https://www.testbraindump.com/CCDAK-exam-prep.html
Best Quality Confluent CCDAK Exam Questions: https://drive.google.com/open?id=1nu0XVzbkaTS71x-fZwiJaV1b5aquZRtY
