Top Tips Of Up To The Immediate Present CCDAK Testing Bible

NEW QUESTION 1
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 2
How will you find out all the partitions without a leader?

• A. kafka-topics.sh --broker-list localhost:9092 --describe --under-replicated-partitions
• B. kafka-topics.sh --bootstrap-server localhost:2181 --describe --unavailable-partitions
• C. kafka-topics.sh --zookeeper localhost:2181 --describe --unavailable-partitions
• D. kafka-topics.sh --zookeeper localhost:2181 --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 3
The rule "same key goes to the same partition" is true unless...

• A. the number of producer changes
• B. the number of kafka broker changes
• C. the number of partition changes
• D. the replication factor changes

Answer: C

Explanation:
Increasing the number of partition causes new messages keys to get hashed differently, and breaks the guarantee "same keys goes to the same partition". Kafka logs are immutable and the previous messages are not re-shuffled.

NEW QUESTION 4
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 5
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 6
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 7
To get acknowledgement of writes to only the leader partition, we need to use the config...

• A. acks=1
• B. acks=0
• C. acks=all

Answer: A

Explanation:
Producers can set acks=1 to get acknowledgement from partition leader only.

NEW QUESTION 8
A consumer starts and has auto.offset.reset=none, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 10 for the topic before. Where will the consumer read from?

• A. offset 45
• B. offset 10
• C. it will crash
• D. offset 2311

Answer: C

Explanation:
auto.offset.reset=none means that the consumer will crash if the offsets it's recovering from have been deleted from Kafka, which is the case here, as 10 < 45

NEW QUESTION 9
You have a consumer group of 12 consumers and when a consumer gets killed by the process management system, rather abruptly, it does not trigger a graceful shutdown of your consumer. Therefore, it takes up to 10 seconds for a rebalance to happen. The business would like to have a 3 seconds rebalance time. What should you do? (select two)

• A. Increase session.timeout.ms
• B. Decrease session.timeout.ms
• C. Increase heartbeat.interval.ms
• D. decrease max.poll.interval.ms
• E. increase max.poll.interval.ms
• F. Decrease heartbeat.interval.ms

Answer: BE

Explanation:
session.timeout.ms must be decreased to 3 seconds to allow for a faster rebalance, and the heartbeat thread must be quicker, so we also need to decrease heartbeat.interval.ms

NEW QUESTION 10
In Kafka, every broker... (select three)

• A. contains all the topics and all the partitions
• B. knows all the metadata for all topics and partitions
• C. is a controller
• D. knows the metadata for the topics and partitions it has on its disk
• E. is a bootstrap broker
• F. contains only a subset of the topics and the partitions

Answer: BEF

Explanation:
Kafka topics are divided into partitions and spread across brokers. Each brokers knows about all the metadata and each broker is a bootstrap broker, but only one of them is elected controller

NEW QUESTION 11
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. 4 GB
• B. 128 GB
• C. 16 GB
• D. 512 MB

Answer: A

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 12
What are the requirements for a Kafka broker to connect to a Zookeeper ensemble? (select two)

• A. Unique value for each broker's zookeeper.connect parameter
• B. Unique values for each broker's broker.id parameter
• C. All the brokers must share the same broker.id
• D. All the brokers must share the same zookeeper.connect parameter

Answer: BD

Explanation:
Each broker must have a unique broker id and connect to the same zk ensemble and root zNode

NEW QUESTION 13
A Zookeeper ensemble contains 5 servers. What is the maximum number of servers that can go missing and the ensemble still run?

• A. 3
• B. 4
• C. 2
• D. 1

Answer: C

Explanation:
majority consists of 3 zk nodes for 5 nodes zk cluster, so 2 can fail

NEW QUESTION 14
Which of the following is true regarding thread safety in the Java Kafka Clients?

• A. One Producer can be safely used in multiple threads
• B. One Consumer can be safely used in multiple threads
• C. One Consumer needs to run in one thread
• D. One Producer needs to be run in one thread

Answer: AC

Explanation:
KafkaConsumer is not thread-safe, KafkaProducer is thread safe.

NEW QUESTION 15
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 16
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 17
......