Which of the following Kafka Streams operators are stateless? (select all that apply)A . mapB . filterC . flatmapD . branchE . groupByF . aggregate View Answer Answer: A,B,C,D,E Explanation: Seehttps://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html#stateless-transformations...
Continue readingWhat 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 with the key K...
Continue readingTwo 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 partitions View Answer Answer: B Explanation: Each consumer is assigned a different partition of the topic to...
Continue readingTo 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 Source View Answer Answer: 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 databases into...
Continue readingWhere 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 crash View Answer Answer: A Explanation: Latest means...
Continue readingHow 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 the message should be...
Continue readingHow 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 . 3 View Answer Answer: C Explanation: we have...
Continue readingIf 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 Producers have to compress...
Continue readingWhich 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.ms View Answer Answer: D Explanation: linger.ms forces the producer to wait to send messages, hence increasing the chance of creating batches...
Continue readingIf 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 automatically create the topic...
Continue reading