CCDAK

is KSQL ANSI SQL compliant?A . YesB . NoView AnswerAnswer: B Explanation: KSQL is not ANSI SQL compliant, for now there are no defined standards on streaming SQL languages

What kind of delivery guarantee this consumer offers? while (true) { ConsumerRecords<String, String> records = consumer.poll(100); try { consumer.commitSync(); } catch (CommitFailedException e) { log.error("commit failed", e) } for (ConsumerRecord<String, String> record records) { System.out.printf("topic = %s, partition = %s, offset = %d, customer = %s, country = %s ",...

A Zookeeper ensemble contains 3 servers. Over which ports the members of the ensemble should be able to communicate in default configuration? (select three)A . 2181B . 3888C . 443D . 2888E . 9092F . 80View AnswerAnswer: A,B,D Explanation: 2181 - client port, 2888 - peer port, 3888 - leader...

You are running a Kafka Streams application in a Docker container managed by Kubernetes, and upon application restart, it takes a long time for the docker container to replicate the state and get back to processing the data . How can you improve dramatically the application restart?A . Mount a...

A producer is sending messages with null key to a topic with 6 partitions using the DefaultPartitioner. Where will the messages be stored?A . Partition 5B . Any of the topic partitionsC . The partition for the null keyD . Partition 0View AnswerAnswer: A Explanation: Message with no keys will...

A kafka topic has a replication factor of 3 and min.insync.replicas setting of 2 . How many brokers can go down before a producer with acks=all can't produce?A . 0B . 2C . 1D . 3View AnswerAnswer: C Explanation: acks=all and min.insync.replicas=2 means we must have at least 2 brokers...

How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?A . Call consumer.wakeUp() and catch a WakeUpExceptionB . Call consumer.poll() in another threadC . Kill the consumer threadView AnswerAnswer: A Explanation: See https://stackoverflow.com/a/37748336/3019499

A Zookeeper ensemble contains 5 servers . What is the maximum number of servers that can go missing and the ensemble still run?A . 3B . 4C . 2D . 1View AnswerAnswer: C Explanation: majority consists of 3 zk nodes for 5 nodes zk cluster, so 2 can fail

You have a Kafka cluster and all the topics have a replication factor of 3. One intern at your company stopped a broker, and accidentally deleted all the data of that broker on the disk . What will happen if the broker is restarted?A . The broker will start, and...

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?A . Increase fetch.max.waitB . Increase fetch.max.bytesC . Decrease fetch.max.bytesD . Decrease fetch.min.bytesE . Increase fetch.min.bytesView AnswerAnswer: E Explanation: This will allow consumers to...