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

问题 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?

问题 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)

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

问题 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?

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

问题 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?

问题 41
Select all that applies (select THREE)

问题 42
Where are the dynamic configurations for a topic stored?

问题 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?

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

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

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

问题 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?

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