Which actions will trigger partition rebalance for a consumer group? (select three)

Which actions will trigger partition rebalance for a consumer group? (select three)A . Increase partitions of a topicB . Remove a broker from the clusterC . Add a new consumer to consumer groupD . A consumer in a consumer group shuts down Add a broker to the clusterView AnswerAnswer: A,C,D...

February 2, 2022 No Comments READ MORE +

Where will the consumer read from?

A consumer starts and has auto.offset.reset=none, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 10 for the topic before. Where will the consumer read from?A . offset 45B . offset 10C . it will crashD . offset...

February 1, 2022 No Comments READ MORE +

Where are the ACLs stored in a Kafka cluster by default?

Where are the ACLs stored in a Kafka cluster by default?A . Inside the broker's data directoryB . Under Zookeeper node /kafka-acl/C . In Kafka topic __kafka_aclsD . Inside the Zookeeper's data directoryView AnswerAnswer: A Explanation: ACLs are stored in Zookeeper node /kafka-acls/ by default.

February 1, 2022 No Comments READ MORE +

What kind of mirroring is this?

A topic "sales" is being produced to in the Americas region. You are mirroring this topic using Mirror Maker to the European region. From there, you are only reading the topic for analytics purposes . What kind of mirroring is this?A . Passive-PassiveB . Active-ActiveC . Active-PassiveView AnswerAnswer: C Explanation:...

February 1, 2022 No Comments READ MORE +

How should you proceed?

An ecommerce website maintains two topics - a high volume "purchase" topic with 5 partitions and low volume "customer" topic with 3 partitions. You would like to do a stream-table join of these topics . How should you proceed?A . Repartition the purchase topic to have 3 partitionsB . Repartition...

February 1, 2022 No Comments READ MORE +

What is a generic unique id that I can use for messages I receive from a consumer?

What is a generic unique id that I can use for messages I receive from a consumer?A . topic + partition + timestampB . topic + partition + offsetC . topic + timestampView AnswerAnswer: B Explanation: (Topic,Partition,Offset) uniquely identifies a message in Kafka

February 1, 2022 No Comments READ MORE +

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

The exactly once guarantee in the Kafka Streams is for which flow of data?A . Kafka => KafkaB . Kafka => ExternalC . External => KafkaView AnswerAnswer: A Explanation: Kafka Streams can only guarantee exactly once processing if you have a Kafka to Kafka topology.

February 1, 2022 No Comments READ MORE +

To continuously export data from Kafka into a target database, I should use

To continuously export data from Kafka into a target database, I should useA . Kafka ProducerB . Kafka StreamsC . Kafka Connect SinkD . Kafka Connect SourceView AnswerAnswer: C Explanation: Kafka Connect Sink is used to export data from Kafka to external databases and Kafka Connect Source is used to...

January 31, 2022 No Comments READ MORE +

What is the maximum number of brokers that can be down so that a producer with acks=all can still produce to the topic?

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?A . 3B . 0C . 2D . 1View AnswerAnswer: C Explanation: Two...

January 31, 2022 No Comments READ MORE +

Where are the dynamic configurations for a topic stored?

Where are the dynamic configurations for a topic stored?A . In ZookeeperB . In an internal Kafka topic __topic_configuratinsC . In server.propertiesD . On the Kafka broker file systemView AnswerAnswer: A Explanation: Dynamic topic configurations are maintained in Zookeeper.

January 31, 2022 No Comments READ MORE +