FRAGE 34
Welche Replik wird standardmäßig als Partitionsleiter gewählt? (zwei auswählen)

FRAGE 35
StreamsBuilder builder = new StreamsBuilder();
KStream textLines = builder.stream("word-count-input"); KTable wordCounts = textLines
.mapValues(textLine -> textLine.toLowerCase())
.flatMapValues(textLine -> Arrays.asList(textLine.split("W+"))))
.selectKey((Schlüssel, Wort) -> Wort)
.groupByKey()
.count(Materialized.as("Counts"));
wordCounts.toStream().to("word-count-output", Produced.with(Serdes.String(), Serdes.Long())); builder.build(); Was ist eine angemessene Themenkonfiguration für das Thema word-count-output?

FRAGE 36
Angenommen, Sie haben 6 Makler und möchten ein Thema mit 10 Partitionen und einem Replikationsfaktor von 3 erstellen. Die Makler 0 und 1 befinden sich auf Rack A, die Makler 2 und 3 auf Rack B und die Makler 4 und 5 auf Rack C.
Wenn sich der Leader für Partition 0 auf Broker 4 und die erste Replik auf Broker 2 befindet, welcher Broker kann die letzte Replik hosten? (zwei auswählen)

FRAGE 37
Die "Exactly Once"-Garantie in den Kafka-Streams gilt für welchen Datenfluss?

FRAGE 38
Sie verwenden einen JDBC-Quellkonnektor, um Daten aus 2 Tabellen in zwei Kafka-Themen zu kopieren. Es wurde ein Konnektor mit max.tasks gleich 2 erstellt, der in einem Cluster mit 3 Workern eingesetzt wird. Wie viele Aufgaben werden gestartet?

FRAGE 39
Wenn Sie einen SSL-Endpunkt in Kafka aktivieren, welche Funktion von Kafka geht dann verloren?

FRAGE 40
Eine Producer-Anwendung auf einem Entwicklerrechner konnte Nachrichten an ein Kafka-Topic senden. Nachdem die Producer-Anwendung auf den Rechner eines anderen Entwicklers kopiert wurde, kann der Producer zwar eine Verbindung zu Kafka herstellen, aber aufgrund eines Autorisierungsproblems keine Nachrichten an dasselbe Kafka-Topic senden. Was ist das wahrscheinliche Problem?

FRAGE 41
Wählen Sie alles, was zutrifft (wählen Sie DREI)

FRAGE 42
Wo werden die dynamischen Konfigurationen für ein Thema gespeichert?

FRAGE 43
Ein Thema hat drei Replikate und Sie setzen min.insync.replicas auf 2. Was passiert, wenn zwei der drei Replikate nicht verfügbar sind, wenn eine Konsumierungsanfrage an den Broker gesendet wird?

FRAGE 44
Welche der folgenden Kafka-Streams-Operatoren sind zustandslos? (alle zutreffenden auswählen)

FRAGE 45
In Avro ist das Entfernen eines Feldes, das keinen Standardwert hat, eine __ Schemaentwicklung

FRAGE 46
Ein Zookeeper-Ensemble besteht aus 5 Servern. Wie viele Server können maximal ausfallen und das Ensemble kann trotzdem weiterlaufen?

FRAGE 47
Ein Verbraucher hat auto.offset.reset=latest, und die Themenpartition hat derzeit Daten für Offsets von 45 bis 2311. Die Verbrauchergruppe hat noch nie Offsets für das Thema festgelegt. Von wo wird der Verbraucher lesen?

FRAGE 48
Welche der folgenden Aussagen über die Anzahl der Partitionen eines Themas sind richtig?