CCDAK Online Practice Questions and Answers

Two consumers share the same group.id (consumer group id). Each consumer will

A. Read mutually exclusive offsets blocks on all the partitions

B. Read all the data on mutual exclusive partitions

C. Read all data from all partitions

The exactly once guarantee in the Kafka Streams is for which flow of data?

A. Kafka => Kafka

B. Kafka => External

C. External => Kafka

A client connects to a broker in the cluster and sends a fetch request for a partition in a topic. It gets an exception Not Leader For Partition Exception in the response. How does client handle this situation?

A. Get the Broker id from Zookeeper that is hosting the leader replica and send request to it

B. Send metadata request to the same broker for the topic and select the broker hosting the leader replica

C. Send metadata request to Zookeeper for the topic and select the broker hosting the leader replica

D. Send fetch request to each Broker in the cluster

If I supply the setting compression.type=snappy to my producer, what will happen? (select two) A. The Kafka brokers have to de-compress the data

B. The Kafka brokers have to compress the data

C. The Consumers have to de-compress the data

D. The Consumers have to compress the data

E. The Producers have to compress the data

A consumer wants to read messages from a specific partition of a topic. How can this be achieved?

A. Call subscribe(String topic, int partition) passing the topic and partition number as the arguments

B. Call assign() passing a Collection of TopicPartitions as the argument

C. Call subscribe() passing TopicPartition as the argument

What Java library is KSQL based on?

A. Kafka Streams

B. REST Proxy

C. Schema Registry

D. Kafka Connect

Which is an optional field in an Avro record?

A. doc

B. name

C. namespace

D. fields

What client protocol is supported for the schema registry? (select two)

A. HTTP

B. HTTPS

C. JDBC

D. Websocket

E. SASL

What is the default port that the KSQL server listens on?

A. 9092

B. 8088

C. 8083

D. 2181

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