CCDAK Free Practice Test

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

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

Correct Answer: A
See https://stackoverflow.com/a/37748336/3019499

A customer has many consumer applications that process messages from a Kafka topic. Each consumer application can only process 50 MB/s. Your customer wants to achieve a target throughput of 1 GB/s. What is the minimum number of partitions will you suggest to the customer for that particular topic?

1. A. 10
2. B. 20
3. C. 1
4. D. 50

Correct Answer: B
each consumer can process only 50 MB/s, so we need at least 20 consumers consuming one partition so that 50 * 20 = 1000 MB target is achieved.

Which Kafka CLI should you use to consume from a topic?

1. A. kafka-console-consumer
2. B. kafka-topics
3. C. kafka-console
4. D. kafka-consumer-groups

Correct Answer: A
Examplekafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic test --from- beginning

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?

1. A. KTable
2. B. GlobalKTable
3. C. You choose between KStream or KTable
4. D. Kstream

Correct Answer: D
Here KStream is being processed to create another KStream.

Which of the following Kafka Streams operators are stateless? (select all that apply)

1. A. map
2. B. filter
3. C. flatmap
4. D. branch
5. E. groupBy
6. F. aggregate

Correct Answer: ABCDE
Seehttps://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html#stateless-transformations