CCDAK Revolutionary Guide To Exam Confluent Dumps
CCDAK Free Study Guide! with New Update 150 Exam Questions
NEW QUESTION 50
To produce data to a topic, a producer must provide the Kafka client with...
- A. any broker from the cluster and the topic name and the partitions list
- B. all the brokers from the cluster and the topic name
- C. any broker from the cluster and the topic name
- D. the list of brokers that have the data, the topic name and the partitions list
Answer: C
Explanation:
All brokers can respond to a Metadata request, so a client can connect to any broker in the cluster and then figure out on its own which brokers to send data to.
NEW QUESTION 51
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. Disable compression
- B. Decrease linger.ms
- C. Increase batch.size
- D. Enable compression
- E. Decrease batch.size
Answer: C,D
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 52
A consumer starts and has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 643 for the topic before. Where will the consumer read from?
- A. offset 643
- B. offset 2311
- C. offset 45
- D. it will crash
Answer: A
Explanation:
The offsets are already committed for this consumer group and topic partition, so the property auto.offset.reset is ignored
NEW QUESTION 53
Two consumers share the same group.id (consumer group id). Each consumer will
- A. Read all the data on mutual exclusive partitions
- B. Read mutually exclusive offsets blocks on all the partitions
- C. Read all data from all partitions
Answer: A
Explanation:
Each consumer is assigned a different partition of the topic to consume.
NEW QUESTION 54
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 customer topic to have 5 partitions
- B. Model customer as a GlobalKTable
- C. Repartition the purchase topic to have 3 partitions
- D. Do a KStream / KTable join after a repartition step
Answer: B
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 55
There are 3 brokers in the cluster. You want to create a topic with a single partition that is resilient to one broker failure and one broker maintenance. What is the replication factor will you specify while creating the topic?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: D
Explanation:
1 is not possible as it doesn't provide resilience to failure, 2 is not enough as if we take a broker down for maintenance, we cannot tolerate a broker failure, and 6 is impossible as we only have 3 brokers (RF cannot be greater than the number of brokers). Here the correct answer is 3
NEW QUESTION 56
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 57
How will you find out all the partitions without a leader?
- A. kafka-topics.sh --bootstrap-server localhost:2181 --describe --unavailable-partitions
- B. kafka-topics.sh --zookeeper localhost:2181 --describe --under-replicated-partitions
- C. kafka-topics.sh --zookeeper localhost:2181 --describe --unavailable-partitions
- D. kafka-topics.sh --broker-list localhost:9092 --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 58
What isn't an internal Kafka Connect topic?
- A. connect-jars
- B. connect-status
- C. connect-offsets
- D. connect-configs
Answer: A
Explanation:
connect-configs stores configurations, connect-status helps to elect leaders for connect, and connect-offsets store source offsets for source connectors
NEW QUESTION 59
A consumer has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group never committed offsets for the topic before. Where will the consumer read from?
- A. offset 2311
- B. offset 0
- C. offset 45
- D. it will crash
Answer: A
Explanation:
Latest means that data retrievals will start from where the offsets currently end
NEW QUESTION 60
A producer application in a developer machine was able to send messages to a Kafka topic. After copying the producer application into another developer's machine, the producer is able to connect to Kafka but unable to produce to the same Kafka topic because of an authorization issue. What is the likely issue?
- A. Broker configuration needs to be changed to allow a different producer
- B. You cannot copy a producer application from one machine to another
- C. The Kafka ACL does not allow another machine IP
- D. The Kafka Broker needs to be rebooted
Answer: C
Explanation:
ACLs take "Host" as a parameter, which represents an IP. It can be * (all IP), or a specific IP. Here, it's a specific IP as moving a producer to a different machine breaks the consumer, so the ACL needs to be updated
NEW QUESTION 61
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: A,B
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 62
A Kafka producer application wants to send log messages to a topic that does not include any key. What are the properties that are mandatory to configure for the producer configuration? (select three)
- A. key
- B. key.serializer
- C. partition
- D. value.serializer
- E. value
- F. bootstrap.servers
Answer: B,D,F
Explanation:
Both key and value serializer are mandatory.
NEW QUESTION 63
Which of the following setting increases the chance of batching for a Kafka Producer?
- A. Increase linger.ms
- B. Increase the number of producer threads
- C. Increase batch.size
- D. Increase message.max.bytes
Answer: A
Explanation:
linger.ms forces the producer to wait to send messages, hence increasing the chance of creating batches
NEW QUESTION 64
Kafka is configured with following parameters - log.retention.hours = 168 log.retention.minutes = 168 log.retention.ms = 168 How long will the messages be retained for?
- A. 168 hours
- B. 168 ms
- C. 168 minutes
- D. Broker will not start due to bad configuration
Answer: B
Explanation:
If more than one similar config is specified, the smaller unit size will take precedence.
NEW QUESTION 65
How will you set the retention for the topic named my-topic to 1 hour?
- A. Set the topic config retention.ms to 3600000
- B. Set the broker config log.retention.ms to 3600000
- C. Set the consumer config retention.ms to 3600000
- D. Set the producer config retention.ms to 3600000
Answer: A
Explanation:
retention.ms can be configured at topic level while creating topic or by altering topic. It shouldn't be set at the broker level (log.retention.ms) as this would impact all the topics in the cluster, not just the one we are interested in
NEW QUESTION 66
......
Get up-to-date Real Exam Questions for CCDAK: https://dumpstorrent.dumpsfree.com/CCDAK-valid-exam.html