CCDAK Online Practice Questions and Answers

StreamsBuilder builder = new StreamsBuilder();

KStream textLines = builder.stream("word-count-input");

KTable wordCounts = textLines

.mapValues(textLine -> textLine.toLowerCase())

.flatMapValues(textLine -> Arrays.asList(textLine.split("\W+"))) .selectKey((key, word) -> word)

.groupByKey()

.count(Materialized.as("Counts"));

wordCounts.toStream().to("word-count-output", Produced.with(Serdes.String(), Serdes.Long()));

builder.build();

What is an adequate topic configuration for the topic word-count-output?

A. max.message.bytes=10000000

B. cleanup.policy=delete

C. compression.type=lz4

D. cleanup.policy=compact

You are using JDBC source connector to copy data from a table to Kafka topic. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many tasks are launched?

A. 3

B. 2

C. 1

D. 6

What data format isn't natively available with the Confluent REST Proxy?

A. avro

B. binary

C. protobuf

D. json

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

Your streams application is reading from an input topic that has 5 partitions. You run 5 instances of your application, each with num.streams.threads set to 5. How many stream tasks will be created and how many will be active?

A. 5 created, 1 active

B. 5 created, 5 active

C. 25 created, 25 active

D. 25 created, 5 active

How will you set the retention for the topic named ‚aumy-topic‚Au to 1 hour?

A. Set the broker config log.retention.ms to 3600000

B. Set the consumer config retention.ms to 3600000

C. Set the topic config retention.ms to 3600000

D. Set the producer config retention.ms to 3600000

A topic receives all the orders for the products that are available on a commerce site. Two applications want to process all the messages independently - order fulfilment and monitoring. The topic has 4 partitions, how would you organise the consumers for optimal performance and resource usage?

A. Create 8 consumers in the same group with 4 consumers for each application

B. Create two consumers groups for two applications with 8 consumers in each

C. Create two consumer groups for two applications with 4 consumers in each

D. Create four consumers in the same group, one for each partition - two for fulfilment and two for monitoring

What Java library is KSQL based on?

A. Kafka Streams

B. REST Proxy

C. Schema Registry

D. Kafka Connect

If a topic has a replication factor of 3...

A. 3 replicas of the same data will live on 1 broker

B. Each partition will live on 4 different brokers

C. Each partition will live on 2 different brokers

D. Each partition will live on 3 different brokers

If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?

A. Cross-cluster mirroring

B. Support for Avro format

C. Zero copy

D. Exactly-once delivery