Free Sales Ending Soon - Use Real CCDAK PDF Questions [Jan 05, 2022]
Updated Jan-2022 Exam CCDAK Dumps - Pass Your Certification Exam
NEW QUESTION 18
A topic has three replicas and you set min.insync.replicas to 2. If two out of three replicas are not available, what happens when a produce request with acks=all is sent to broker?
- A. Produce request is honored with single in-sync replica
- B. Produce request will block till one of the two unavailable partition is available again.
- C. NotEnoughReplicasException will be returned
Answer: C
Explanation:
With this configuration, a single in-sync replica becomes read-only. Produce request will receive NotEnoughReplicasException.
NEW QUESTION 19
You have a Zookeeper cluster that needs to be able to withstand the loss of 2 servers and still be able to function. What size should your Zookeeper cluster have?
- A. 0
- B. 1
- C. 2
- D. 3
- E. 4
Answer: D
Explanation:
Your Zookeeper cluster needs to have an odd number of servers, and must maintain a majority of servers up to be able to vote. Therefore, a 2N+1 zookeeper cluster can survive to N zookeeper being down, so here the right answer is N=2, 2*N+1=5
NEW QUESTION 20
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 21
How much should be the heap size of a broker in a production setup on a machine with 256 GB of RAM, in PLAINTEXT mode?
- A. 16 GB
- B. 128 GB
- C. 4 GB
- D. 512 MB
Answer: C
Explanation:
In Kafka, a small heap size is needed, while the rest of the RAM goes automatically to the page cache (managed by the OS). The heap size goes slightly up if you need to enable SSL
NEW QUESTION 22
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 23
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 24
You are doing complex calculations using a machine learning framework on records fetched from a Kafka topic. It takes more about 6 minutes to process a record batch, and the consumer enters rebalances even though it's still running. How can you improve this scenario?
- A. Increase session.timeout.ms to 600000
- B. Add consumers to the consumer group and kill them right away
- C. Increase heartbeat.interval.ms to 600000
- D. Increase max.poll.interval.ms to 600000
Answer: D
Explanation:
Here, we need to change the setting max.poll.interval.ms (default 300000) to its double in order to tell Kafka a consumer should be considered dead if the consumer only if it hasn't called the .poll() method in 10 minutes instead of 5.
NEW QUESTION 25
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
- A. Commit offsets at 11
- B. Do not commit until successfully processing the record #10
- C. Commit offsets at 10
Answer: A
Explanation:
Here, you shouldn't commit offsets 11 or 10 as it would indicate that the message #10 has been processed successfully.
NEW QUESTION 26
Which of the following statements are true regarding the number of partitions of a topic?
- A. We can remove partitions in a topic by removing a broker
- B. We can remove partitions in a topic using the kafka-topics.sh command
- C. The number of partitions in a topic cannot be altered
- D. We can add partitions in a topic by adding a broker to the cluster
- E. We can add partitions in a topic using the kafka-topics.sh command
Answer: E
Explanation:
We can only add partitions to an existing topic, and it must be done using the kafka-topics.sh command
NEW QUESTION 27
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?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: C
Explanation:
JDBC connector allows one task per table.
NEW QUESTION 28
What client protocol is supported for the schema registry? (select two)
- A. Websocket
- B. HTTP
- C. JDBC
- D. HTTPS
- E. SASL
Answer: B,D
Explanation:
clients can interact with the schema registry using the HTTP or HTTPS interface
NEW QUESTION 29
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 30
You are running a Kafka Streams application in a Docker container managed by Kubernetes, and upon application restart, it takes a long time for the docker container to replicate the state and get back to processing the dat a. How can you improve dramatically the application restart?
- A. Mount a persistent volume for your RocksDB
- B. Increase the number of Streams threads
- C. Increase the number of partitions in your inputs topic
- D. Reduce the Streams caching property
Answer: A
Explanation:
Although any Kafka Streams application is stateless as the state is stored in Kafka, it can take a while and lots of resources to recover the state from Kafka. In order to speed up recovery, it is advised to store the Kafka Streams state on a persistent volume, so that only the missing part of the state needs to be recovered.
NEW QUESTION 31
There are five brokers in a cluster, a topic with 10 partitions and replication factor of 3, and a quota of producer_bytes_rate of 1 MB/sec has been specified for the client. What is the maximum throughput allowed for the client?
- A. 0.33 MB/s
- B. 5 MB/s
- C. 10 MB/s
- D. 1 MB/s
Answer: B
Explanation:
Each producer is allowed to produce @ 1MB/s to a broker. Max throughput 5 * 1MB, because we have 5 brokers.
NEW QUESTION 32
Which of the following Kafka Streams operators are stateless? (select all that apply)
- A. map
- B. aggregate
- C. branch
- D. filter
- E. flatmap
- F. groupBy
Answer: A,C,D,E,F
Explanation:
Seehttps://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html#stateless-transformations
NEW QUESTION 33
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=false
- B. Any of the replicas
- C. Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=true
- D. An in-sync replica
Answer: B,D
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 34
Which of the following errors are retriable from a producer perspective? (select two)
- A. INVALID_REQUIRED_ACKS
- B. NOT_LEADER_FOR_PARTITION
- C. TOPIC_AUTHORIZATION_FAILED
- D. NOT_ENOUGH_REPLICAS
- E. MESSAGE_TOO_LARGE
Answer: B,D
Explanation:
Both of these are retriable errors, others non-retriable errors. See the full list of errors and their "retriable" status herehttps://kafka.apache.org/protocol#protocol_error_codes
NEW QUESTION 35
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. 0
- B. 1
- C. 2
- D. 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 36
What is not a valid authentication mechanism in Kafka?
- A. SASL/GSSAPI
- B. SSL
- C. SAML
- D. SASL/SCRAM
Answer: C
Explanation:
Learn more about security herehttps://kafka.apache.org/documentation/#security
NEW QUESTION 37
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 38
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 39
What isn't a feature of the Confluent schema registry?
- A. Enforce compatibility rules
- B. Store avro data
- C. Store schemas
Answer: B
Explanation:
Data is stored on brokers.
NEW QUESTION 40
Which KSQL queries write to Kafka?
- A. CREATE STREAM AS SELECT and CREATE TABLE AS SELECT
- B. CREATE STREAM WITH <topic> and CREATE TABLE WITH <topic>
- C. COUNT and JOIN
- D. SHOW STREAMS and EXPLAIN <query> statements
Answer: A,B
Explanation:
SHOW STREAMS and EXPLAIN <query> statements run against the KSQL server that the KSQL client is connected to. They don't communicate directly with Kafka. CREATE STREAM WITH <topic> and CREATE TABLE WITH <topic> write metadata to the KSQL command topic. Persistent queries based on CREATE STREAM AS SELECT and CREATE TABLE AS SELECT read and write to Kafka topics. Non-persistent queries based on SELECT that are stateless only read from Kafka topics, for example SELECT * FROM foo WHERE. Non-persistent queries that are stateful read and write to Kafka, for example, COUNT and JOIN. The data in Kafka is deleted automatically when you terminate the query with CTRL-C.
NEW QUESTION 41
What information isn't stored inside of Zookeeper? (select two)
- A. Schema Registry schemas
- B. ACL inforomation
- C. Controller registration
- D. Broker registration info
- E. Consumer offset
Answer: E
Explanation:
Consumer offsets are stored in a Kafka topic __consumer_offsets, and the Schema Registry stored schemas in the _schemas topic.
NEW QUESTION 42
To get acknowledgement of writes to only the leader partition, we need to use the config...
- A. acks=0
- B. acks=1
- C. acks=all
Answer: B
Explanation:
Producers can set acks=1 to get acknowledgement from partition leader only.
NEW QUESTION 43
......
CCDAK Dumps To Pass Confluent Certified Developer Exam in One Day: https://www.practicematerial.com/CCDAK-exam-materials.html
Latest Real Confluent CCDAK Exam Dumps Questions: https://drive.google.com/open?id=1NNck5PqhIFZ7nkxztDH_33TomrWo3dfu
