The Far Out Guide To CCDAK Pdf

NEW QUESTION 1
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. Broker will not start due to bad configuration
• B. 168 ms
• C. 168 hours
• D. 168 minutes

Answer: B

Explanation:
If more than one similar config is specified, the smaller unit size will take precedence.

NEW QUESTION 2
How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?

• A. Call consumer.wakeUp() and catch a WakeUpException
• B. Call consumer.poll() in another thread
• C. Kill the consumer thread

Answer: A

Explanation:
See https://stackoverflow.com/a/37748336/3019499

NEW QUESTION 3
In Avro, removing or adding a field that has a default is a schema evolution

• A. full
• B. backward
• C. breaking
• D. forward

Answer: A

Explanation:
Clients with new schema will be able to read records saved with old schema and clients with old schema will be able to read records saved with new schema.

NEW QUESTION 4
Once sent to a topic, a message can be modified

• A. No
• B. Yes

Answer: A

Explanation:
Kafka logs are append-only and the data is immutable

NEW QUESTION 5
Where are the ACLs stored in a Kafka cluster by default?

• A. Inside the broker's data directory
• B. Under Zookeeper node /kafka-acl/
• C. In Kafka topic kafka_acls
• D. Inside the Zookeeper's data directory

Answer: A

Explanation:
ACLs are stored in Zookeeper node /kafka-acls/ by default.

NEW QUESTION 6
Which of the following statements are true regarding the number of partitions of a topic?

• A. The number of partitions in a topic cannot be altered
• B. We can add partitions in a topic by adding a broker to the cluster
• C. We can add partitions in a topic using the kafka-topics.sh command
• D. We can remove partitions in a topic by removing a broker
• E. We can remove partitions in a topic using the kafka-topics.sh command

Answer: C

Explanation:
We can only add partitions to an existing topic, and it must be done using the kafka- topics.sh command

NEW QUESTION 7
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 8
Which actions will trigger partition rebalance for a consumer group? (select three)

• A. Increase partitions of a topic
• B. Remove a broker from the cluster
• C. Add a new consumer to consumer group
• D. A consumer in a consumer group shuts down Add a broker to the cluster

Answer: ACD

Explanation:
Rebalance occurs when a new consumer is added, removed or consumer dies or paritions increased.

NEW QUESTION 9
How do Kafka brokers ensure great performance between the producers and consumers? (select two)

• A. It compresses the messages as it writes to the disk
• B. It leverages zero-copy optimisations to send data straight from the page-cache
• C. It buffers the messages on disk, and sends messages from the disk reads
• D. It transforms the messages into a binary format
• E. It does not transform the messages

Answer: BE

Explanation:
Kafka transfers data with zero-copy and sends the raw bytes it receives from the producer
straight to the consumer, leveraging the RAM available as page cache

NEW QUESTION 10
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 11
A consumer application is using KafkaAvroDeserializer to deserialize Avro messages. What happens if message schema is not present in AvroDeserializer local cache?

• A. Throws SerializationException
• B. Fails silently
• C. Throws DeserializationException
• D. Fetches schema from Schema Registry

Answer: D

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 12
To produce data to a topic, a producer must provide the Kafka client with...

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

Answer: D

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 13
Which of the following errors are retriable from a producer perspective? (select two)

• A. MESSAGE_TOO_LARGE
• B. INVALID_REQUIRED_ACKS
• C. NOT_ENOUGH_REPLICAS
• D. NOT_LEADER_FOR_PARTITION
• E. TOPIC_AUTHORIZATION_FAILED

Answer: CD

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 14
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 15
Which is an optional field in an Avro record?

• A. doc
• B. name
• C. namespace
• D. fields

Answer: A

Explanation:
doc represents optional description of message

NEW QUESTION 16
To prevent network-induced duplicates when producing to Kafka, I should use

• A. max.in.flight.requests.per.connection=1
• B. enable.idempotence=true
• C. retries=200000
• D. batch.size=1

Answer: B

Explanation:
Producer idempotence helps prevent the network introduced duplicates. More details herehttps://cwiki.apache.org/confluence/display/KAFKA/Idempotent+Producer

NEW QUESTION 17
When using the Confluent Kafka Distribution, where does the schema registry reside?

• A. As a separate JVM component
• B. As an in-memory plugin on your Zookeeper cluster
• C. As an in-memory plugin on your Kafka Brokers
• D. As an in-memory plugin on your Kafka Connect Workers

Answer: A

Explanation:
Schema registry is a separate application that provides RESTful interface for storing and retrieving Avro schemas.

NEW QUESTION 18
......