質問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?