NO.23 What information isn’t stored inside of Zookeeper? (select two)

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

NO.25 You have a Zookeeper cluster that needs to be able to withstand the loss of 2 servers and still be able to function. What size should your Zookeeper cluster have?

NO.26 What exceptions may be caught by the following producer? (select two)
ProducerRecord<String, String> record =
new ProducerRecord<>(“topic1”, “key1”, “value1”);
try {
producer.send(record);
} catch (Exception e) {
e.printStackTrace();
}

NO.27 Which of the following setting increases the chance of batching for a Kafka Producer?

NO.28 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?

NO.29 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?

NO.30 A topic has three replicas and you set min.insync.replicas to 2. If two out of three replicas are not available, what happens when a consume request is sent to broker?

NO.31 Your producer is producing at a very high rate and the batches are completely full each time. How can you improve the producer throughput? (select two)

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

NO.33 To read data from a topic, the following configuration is needed for the consumers

NO.34 What happens when broker.rack configuration is provided in broker configuration in Kafka cluster?

NO.35 What is not a valid authentication mechanism in Kafka?

NO.36 Which of the following Kafka Streams operators are stateful? (select all that apply)

NO.37 To transform data from a Kafka topic to another one, I should use

NO.38 Where are the dynamic configurations for a topic stored?

NO.39 What is the disadvantage of request/response communication?

NO.40 If I supply the setting compression.type=snappy to my producer, what will happen? (select two)

NO.41 What happens if you write the following code in your producer? producer.send(producerRecord).get()

NO.42 In the Kafka consumer metrics it is observed that fetch-rate is very high and each fetch is small. What steps will you take to increase throughput?

NO.43 Partition leader election is done by

NO.44 Compaction is enabled for a topic in Kafka by setting log.cleanup.policy=compact. What is true about log compaction?

NO.45 What is the default port that the KSQL server listens on?