QUESTION 34
By default, which replica will be elected as a partition leader? (select two)

QUESTION 35
StreamsBuilder builder = new StreamsBuilder();
KStream<String, String> textLines = builder.stream(“word-count-input”); KTable<String, Long> wordCounts = textLines
.mapValues(textLine -> textLine.toLowerCase())
.flatMapValues(textLine -> Arrays.asList(textLine.split(“W+”)))
.selectKey((key, word) -> word)
.groupByKey()
.count(Materialized.as(“Counts”));
wordCounts.toStream().to(“word-count-output”, Produced.with(Serdes.String(), Serdes.Long())); builder.build(); What is an adequate topic configuration for the topic word-count-output?

QUESTION 36
Suppose you have 6 brokers and you decide to create a topic with 10 partitions and a replication factor of 3. The brokers 0 and 1 are on rack A, the brokers 2 and 3 are on rack B, and the brokers 4 and 5 are on rack C.
If the leader for partition 0 is on broker 4, and the first replica is on broker 2, which broker can host the last replica? (select two)

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

QUESTION 38
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?

QUESTION 39
If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?

QUESTION 40
A producer application in a developer machine was able to send messages to a Kafka topic. After copying the producer application into another developer’s machine, the producer is able to connect to Kafka but unable to produce to the same Kafka topic because of an authorization issue. What is the likely issue?

QUESTION 41
Select all that applies (select THREE)

QUESTION 42
Where are the dynamic configurations for a topic stored?

QUESTION 43
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?

QUESTION 44
Which of the following Kafka Streams operators are stateless? (select all that apply)

QUESTION 45
In Avro, removing a field that does not have a default is a __ schema evolution

QUESTION 46
A Zookeeper ensemble contains 5 servers. What is the maximum number of servers that can go missing and the ensemble still run?

QUESTION 47
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?

QUESTION 48
Which of the following statements are true regarding the number of partitions of a topic?