- All Exams Instant Download
Which of the following Kafka Streams operators are stateless? (select all that apply)
Which of the following Kafka Streams operators are stateless? (select all that apply)A . mapB . filterC . flatmapD . branchE . groupByF . aggregateView AnswerAnswer: A,B,C,D,E Explanation: Seehttps://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html#stateless-transformations
What will happen?
Your topic is log compacted and you are sending a message with the key K and value null . What will happen?A . The broker will delete all messages with the key K upon cleanupB . The producer will throw a Runtime exceptionC . The broker will delete the message...
Two consumers share the same group.id (consumer group id). Each consumer will
Two consumers share the same group.id (consumer group id). Each consumer willA . Read mutually exclusive offsets blocks on all the partitionsB . Read all the data on mutual exclusive partitionsC . Read all data from all partitionsView AnswerAnswer: B Explanation: Each consumer is assigned a different partition of the...
To import data from external databases, I should use
To import data from external databases, I should useA . Confluent REST ProxyB . Kafka Connect SinkC . Kafka StreamsD . Kafka Connect SourceView AnswerAnswer: D Explanation: Kafka Connect Sink is used to export data from Kafka to external databases and Kafka Connect Source is used to import from external...
Where will the consumer read from?
A consumer has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group never committed offsets for the topic before. Where will the consumer read from?A . offset 2311B . offset 0C . offset 45D . it will crashView AnswerAnswer: A Explanation:...
How can this be achieved?
You are receiving orders from different customer in an "orders" topic with multiple partitions. Each message has the customer name as the key. There is a special customer named ABC that generates a lot of orders and you would like to reserve a partition exclusively for ABC. The rest of...
How many tasks are launched?
You are using JDBC source connector to copy data from 2 tables to two Kafka topics. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers . How many tasks are launched?A . 6B . 1C . 2D . 3View AnswerAnswer: C Explanation:...
If I supply the setting compression.type=snappy to my producer, what will happen? (select two)
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 dataB . The Kafka brokers have to compress the dataC . The Consumers have to de-compress the dataD . The Consumers have to compress the dataE . The...
Which of the following setting increases the chance of batching for a Kafka Producer?
Which of the following setting increases the chance of batching for a Kafka Producer?A . Increase batch.sizeB . Increase message.max.bytesC . Increase the number of producer threadsD . Increase linger.msView AnswerAnswer: D Explanation: linger.ms forces the producer to wait to send messages, hence increasing the chance of creating batches
If I produce to a topic that does not exist, and the broker setting auto.create.topic.enable=true, what will happen?
If I produce to a topic that does not exist, and the broker setting auto.create.topic.enable=true, what will happen?A . Kafka will automatically create the topic with 1 partition and 1 replication factorB . Kafka will automatically create the topic with the indicated producer settings num.partitions and default.replication.factorC . Kafka will...
