CCDAK Exam Question 36
A kafka topic has a replication factor of 3 and min.insync.replicas setting of 1. What is the maximum number of brokers that can be down so that a producer with acks=all can still produce to the topic?
CCDAK Exam Question 37
A consumer application is using KafkaAvroDeserializer to deserialize Avro messages. What happens if message schema is not present in AvroDeserializer local cache?
CCDAK Exam Question 38
Select the Kafka Streams joins that are always windowed joins.
CCDAK Exam Question 39
I am producing Avro data on my Kafka cluster that is integrated with the Confluent Schema Registry. After a schema change that is incompatible, I know my data will be rejected. Which component will reject the data?
CCDAK Exam Question 40
A consumer is configured with enable.auto.commit=false. What happens when close() is called on the consumer object?