Get Perfect Results with Premium CCDAK Dumps Updated 92 Questions
Free CCDAK Exam Study Guide for the NEW Dumps Test Engine
NEW QUESTION # 17
You are sending messages to a Kafka cluster in JSON format and want to add more information related to each message:
Format of the message payload
Message creation time
A globally unique identifier that allows the message to be traced through the systemWhere should this additional information be set?
- A. Header
- B. Key
- C. Value
- D. Broker
Answer: A
Explanation:
Kafka message headers are the right place to include metadata such as:
Payload format (e.g., schema version)
Timestamps (custom)
Trace or correlation IDs
From Kafka Producer API Docs:
"Headers are a map of key-value pairs that can be used to include metadata alongside the message, without modifying the message body." Keys determine partitioning and ordering Values are the message payload Brokers do not store arbitrary metadata fields Reference: Kafka ProducerRecord API > Headers
NEW QUESTION # 18
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. Do not commit until successfully processing the record #10
- B. Commit offsets at 10
- C. Commit offsets at 11
Answer: C
Explanation:
Here, you shouldn't commit offsets 11 or 10 as it would indicate that the message #10 has been processed successfully.
NEW QUESTION # 19
A consumer application is using KafkaAvroDeserializer to deserialize Avro messages. What happens if message schema is not present in AvroDeserializer local cache?
- A. Fetches schema from Schema Registry
- B. Fails silently
- C. Throws SerializationException
- D. Throws DeserializationException
Answer: A
Explanation:
First local cache is checked for the message schema. In case of cache miss, schema is pulled from the schema registry. An exception will be thrown in the Schema Registry does not have the schema (which should never happen if you set it up properly)
NEW QUESTION # 20
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. Increase linger.ms
- C. Decrease linger.ms
- D. Disable compression
- E. Enable compression
- F. Decrease batch.size
Answer: A,E
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 # 21
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. Passive-Passive
- B. Active-Active
- C. Active-Passive
Answer: C
Explanation:
This is active-passing as the replicated topic is used for read-only purposes only
NEW QUESTION # 22
What is the protocol used by Kafka clients to securely connect to the Confluent REST Proxy?
- A. HTTP
- B. Kerberos
- C. HTTPS (SSL/TLS)
- D. SASL
Answer: C
Explanation:
TLS - but it is still called SSL.
NEW QUESTION # 23
What is returned by a producer.send() call in the Java API?
- A. Future<RecordMetadata> object
- B. A Boolean indicating if the call succeeded
- C. Future<ProducerRecord> object
- D. Unit
Answer: A
Explanation:
Seehttps://kafka.apache.org/21/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html
NEW QUESTION # 24
What is not a valid authentication mechanism in Kafka?
- A. SSL
- B. SASL/GSSAPI
- C. SAML
- D. SASL/SCRAM
Answer: C
Explanation:
Learn more about security herehttps://kafka.apache.org/documentation/#security
NEW QUESTION # 25
Which two statements are correct when assigning partitions to the consumers in a consumer group using the assign() API?
(Select two.)
- A. The consumer group will not be rebalanced if a consumer leaves the group.
- B. The consumer chooses which partition to read without any assignment from brokers.
- C. All topics must have the same number of partitions to use assign() API.
- D. It is mandatory to subscribe to a topic before calling assign() to assign partitions.
Answer: A,B
Explanation:
Using assign() givesmanual controlover partition assignment. In this mode:
* B is true: The applicationchooses partitionsdirectly without involving the group coordinator.
* C is true: Since no group coordination occurs,no rebalancinghappens if a consumer dies.
FromKafka Consumer API Docs:
"assign() manually assigns a list of partitions to this consumer. No coordination takes place and no rebalancing is triggered."
* A is false: subscribe() and assign() aremutually exclusive.
* D is incorrect: Partitions don't need to be equal across topics.
Reference:Kafka Consumer Java API > assign() and subscribe()
NEW QUESTION # 26
Which statement describes the storage location for a sink connector's offsets?
- A. The topic specified in the offsets.storage.topic configuration parameter
- B. In a file specified by the offset.storage.file.filename configuration parameter
- C. In memory which is then periodically flushed to a RocksDB instance
- D. The __consumer_offsets topic, like any other consumer
Answer: D
Explanation:
Kafka Connect sink connectors use the standard Kafka consumer mechanism to track offsets, which means offsets are stored in the __consumer_offsets internal topic.
From Kafka Connect Documentation:
"Sink connectors are regular Kafka consumers and store their offsets in the __consumer_offsets topic like any other consumer." The other options refer to source connectors or worker configuration.
offsets.storage.topic is relevant for source connectors.
Reference: Kafka Connect Concepts > Sink Connectors and Offset Storage
NEW QUESTION # 27
You are using JDBC source connector to copy data from 2 tables to two Kafka topics. 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: B
Explanation:
we have two tables, so the max number of tasks is 2
NEW QUESTION # 28
Which KSQL queries write to Kafka?
- A. CREATE STREAM AS SELECT and CREATE TABLE AS SELECT
- B. COUNT and JOIN
- C. SHOW STREAMS and EXPLAIN <query> statements
- D. CREATE STREAM WITH <topic> and CREATE TABLE WITH <topic>
Answer: A,D
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 # 29
What is the difference between exactly once semantics (EOS) and idempotence?
- A. Idempotence sends an update once and only one item. EOS is any function that can be executed several times without changing the final result beyond its first iteration
- B. Idempotence sends an update multiple times and only keeps the latest update EOS requests get sent multiple times, but only the first request is accepted.
- C. Idempotence Is any function that can be executed several times without changing the final result beyond its first iteration. EOS sends an update once and only one time.
- D. Idempotence sends updates multiple times and stores the first value. EOS sends updates multiple times and stores the latest value.
Answer: C
NEW QUESTION # 30
You need to correctly join data from two Kafka topics.
What will allow for the co-partitioning? (Choose 2.)
- A. Both topics have the same value schema.
- B. Both topics have the same number of partitions.
- C. Both topics have the same key and partitioning strategy.
- D. Both topics have the same retention time.
Answer: B,C
NEW QUESTION # 31
Which actions will trigger partition rebalance for a consumer group? (select three)
- A. Add a new consumer to consumer group
- B. Remove a broker from the cluster
- C. A consumer in a consumer group shuts down
- D. Increase partitions of a topic
Answer: A,C,D
Explanation:
Add a broker to the cluster
Explanation:
Rebalance occurs when a new consumer is added, removed or consumer dies or paritions increased.
NEW QUESTION # 32
......
CCDAK PDF Dumps Extremely Quick Way Of Preparation: https://examsboost.realexamfree.com/CCDAK-real-exam-dumps.html
