Certyfikat

Question 1

Jaki jest domyślny log.retention.hours?

Answer 1

1 week

Question 2

Jakie sąmożliwości konfiguracji retention policy? (per-co)

Answer 2

Globally or per-topic

Question 3

Kiedy można usunąć segment?

Answer 3

Gdy najnowsza wiadomośćw nim jest starsza niżretention period

Question 4

Cztery rzeczy, z których składa sięProducerRecord, i które sąwymagane

Answer 4

Topic
[Partition]
[Key]
Value

Question 5

Jakie sąmożliwe wartości acks?

Answer 5

0
1
all

Question 6

Co to znaczy acks=all?

Answer 6

Wszystkie in-sync replicas muszązapisać

Question 7

Kafka daje exactly-once co?

Answer 7

Processing (nie delivery)

Question 8

Co trzeba zrobićżeby dwa consumery trafiły do tej samej consumer groupy?

Answer 8

Ustawićim takie samo group ID

Question 9

Czy jeden consumer może czytaćz wielu partycji?

Answer 9

Tak

Question 10

Czy wiele consumerów może czytać z jednej partycji?

Answer 10

Nie

Question 11

Co dzieje sięze stanem consumera, gdy padłi jest rebalancing?

Answer 11

Jest tracony

Question 12

Czy Kafka wspiera encryption in transit?

Answer 12

Tak

Question 13

Czy Kafka wspiera encryption at rest?

Answer 13

Nie.

Trzeba zrobićalbo full disc encryption, albo robićto na poziomie aplikacji

Question 14

Kiedy tworzy siętopic, przy opcji auto.create.topics.enable=true?

Answer 14

Gdy próbujemy wysłać wiadomość na nieistniejący topic

Question 15

Jak sięnazywa klasa producera?

Answer 15

KafkaProducer

Question 16

Jak sięnazywa klasa wiadomości, którąwysyłamy?

Answer 16

ProducerRecord

Question 17

Kto decyduje o tym, na jaką partycjętrafia wiadomość?

Answer 17

Producer

Question 18

Jak sięnazywa klasa consumera?

Answer 18

KafkaConsumer

Question 19

Jaka metoda określa, z jakiego topica ma czytaćconsumer? Co może przyjąć?

Answer 19

consumer.subscribe

Może przyjąć topic, listę topików lub pattern

Question 20

Jak sięnazywa klasa tego, co dostaje consumer?

Answer 20

ConsumerRecords, a to ma w sobie ileśConsumerRecord

Question 21

Kiedy zachodzi rebalancing?

Answer 21

Kiedy dodajemy lub usuwamy consumera

Question 22

Czy group.id jest wymagany w consumerze?

Answer 22

Tak

Question 23

Jaki jest defaultowy batch.size?

Answer 23

16384

Question 24

Jaki jest defaultowy linger.ms?

Answer 24

0

Question 25

Jak sięnazywa ustawienie dla maksymalnej wielkości wiadomości na brokerze i jaki ma default?

Answer 25

message.max.bytes, 1MB

Question 26

Jak się nazywa ustawienie dla maksymalnej wielkości wiadomości na topiku i jaki ma default?

Answer 26

max.message.bytes, 1MB

Question 27

Jakie są możliwe liczby node’ów dla Zookeeper ensemble?

Answer 27

Nieparzyste

Question 28

Jakie sąwymagane parametry konfiguracji dla producera?

Answer 28

bootstrap.server, key.serializer, value.serializer

Question 29

Jaki jest defaultowy replication factor?

Answer 29

1

Question 30

Jaki jest domyślny min.insync.replicas?

Answer 30

1

Question 31

Na czym ustawia sięacks?

Answer 31

Na producerze

Question 32

Na czym ustawia sięmin.insync.replicas?

Answer 32

Na brokerze lub topicu

Question 33

Na czym ustawia sięreplication factor?

Answer 33

Na topicu

Question 34

Czy w replication factor wlicza sięlidera?

Answer 34

Tak

Question 35

Jaki jest związek między acks a min.insync.replicas?

Answer 35

Związek jest przy acks=all. Jeśli żaden follower nie jest in-sync, to acks=all mogłoby sięzdegenerować do acks=1. Żeby tego uniknąć, używamy min.insync.replicas.

Question 36

Co siędzieje przy acks=all, min.insync.replicas=2, są3 repliki in-sync, ale tylko od dwóch lider dostał ack?

Answer 36

Poczeka na trzecią

Question 37

Czym jest worker w Kafka Connect? Kto zarządza workerami?

Answer 37

Proces na którym chodzi jeden lub więcej tasków, każdy w osobnym wątku. Kafka Connect rozdziela taski po workerach. Workery nie sązarządzane przez Kafkę, trzeba to robićsamemu

Question 38

Co siędzieje gdy worker w Kafka Connect ulegnie awarii? Kto tym zarządza?

Answer 38

Jego taski zostanąprzeniesione na inny worker. Zarządza tym leader worker

Question 39

Jaki jest domyślny compatibility type w Schema Registry?

Answer 39

backward

Question 40

Przy jakim/jakich compatibility type dozwolone jest usunięcie wymaganego pola?

Answer 40

backward

Question 41

Przy jakim/jakich compatibility type dozwolone jest dodanie opcjonalnego pola?

Answer 41

backward, full

Question 42

Przy jakim/jakich compatibility type dozwolone jest dodanie wymaganego pola?

Answer 42

forward

Question 43

Przy jakim/jakich compatibility type dozwolone jest usunięcie opcjonalnego pola?

Answer 43

forward, full

Question 44

Przy backward compatibility, najpierw upgradujemy producerów czy consumerów?

Answer 44

Consumerów

Question 45

Przy forward compatibility, najpierw upgradujemy producerów czy consumerów?

Answer 45

Producerów

Question 46

Gdy włączone jest auto.create.topics.enable=true i tworzy sięnowy topic, jaka jest liczba partycji i replication factor?

Answer 46

Ustawienia brane z brokera: num.partitions i default.replication.factor

Question 47

Co to jest zero-copy i dlaczego jest ważne w kafce?

Answer 47

Kopiowanie jest z pominięciem aplikacji, z dysku do socketa. To zmniejsza liczbęcontext switchy między kernel mode i user mode, nie zużywa cykli CPU. Daje to kafce szybkość

Question 48

Jak wygląda kompresja gdy mamy batche?

Answer 48

Cały batch jest kompresowany, i w tej formie jest wysyłany i zapisany na serwerze. Dopiero konsumer to dekompresuje

Question 49

Jaki powinien byćbatch.size jeśli chcemy miećwysoki thoughput producera?

Answer 49

Tak duży jak to tylko możliwe, przy nieprzekraczaniu dostępnej pamięci.

Question 50

Co oznacza unclean.leader.election.enable=true?

Answer 50

Liderami mogązostaćrepliki, które sąout-of-sync, więc możemy tracić wiadomości