Certyfikat Flashcards
Jaki jest domyślny log.retention.hours?
1 week
Jakie sąmożliwości konfiguracji retention policy? (per-co)
Globally or per-topic
Kiedy można usunąć segment?
Gdy najnowsza wiadomośćw nim jest starsza niżretention period
Cztery rzeczy, z których składa sięProducerRecord, i które sąwymagane
Topic
[Partition]
[Key]
Value
Jakie sąmożliwe wartości acks?
0
1
all
Co to znaczy acks=all?
Wszystkie in-sync replicas muszązapisać
Kafka daje exactly-once co?
Processing (nie delivery)
Co trzeba zrobićżeby dwa consumery trafiły do tej samej consumer groupy?
Ustawićim takie samo group ID
Czy jeden consumer może czytaćz wielu partycji?
Tak
Czy wiele consumerów może czytać z jednej partycji?
Nie
Co dzieje sięze stanem consumera, gdy padłi jest rebalancing?
Jest tracony
Czy Kafka wspiera encryption in transit?
Tak
Czy Kafka wspiera encryption at rest?
Nie.
Trzeba zrobićalbo full disc encryption, albo robićto na poziomie aplikacji
Kiedy tworzy siętopic, przy opcji auto.create.topics.enable=true?
Gdy próbujemy wysłać wiadomość na nieistniejący topic
Jak sięnazywa klasa producera?
KafkaProducer
Jak sięnazywa klasa wiadomości, którąwysyłamy?
ProducerRecord
Kto decyduje o tym, na jaką partycjętrafia wiadomość?
Producer
Jak sięnazywa klasa consumera?
KafkaConsumer
Jaka metoda określa, z jakiego topica ma czytaćconsumer? Co może przyjąć?
consumer.subscribe
Może przyjąć topic, listę topików lub pattern
Jak sięnazywa klasa tego, co dostaje consumer?
ConsumerRecords, a to ma w sobie ileśConsumerRecord
Kiedy zachodzi rebalancing?
Kiedy dodajemy lub usuwamy consumera
Czy group.id jest wymagany w consumerze?
Tak
Jaki jest defaultowy batch.size?
16384
Jaki jest defaultowy linger.ms?
0
Jak sięnazywa ustawienie dla maksymalnej wielkości wiadomości na brokerze i jaki ma default?
message.max.bytes, 1MB
Jak się nazywa ustawienie dla maksymalnej wielkości wiadomości na topiku i jaki ma default?
max.message.bytes, 1MB
Jakie są możliwe liczby node’ów dla Zookeeper ensemble?
Nieparzyste
Jakie sąwymagane parametry konfiguracji dla producera?
bootstrap.server, key.serializer, value.serializer
Jaki jest defaultowy replication factor?
1
Jaki jest domyślny min.insync.replicas?
1
Na czym ustawia sięacks?
Na producerze
Na czym ustawia sięmin.insync.replicas?
Na brokerze lub topicu
Na czym ustawia sięreplication factor?
Na topicu
Czy w replication factor wlicza sięlidera?
Tak
Jaki jest związek między acks a min.insync.replicas?
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.
Co siędzieje przy acks=all, min.insync.replicas=2, są3 repliki in-sync, ale tylko od dwóch lider dostał ack?
Poczeka na trzecią
Czym jest worker w Kafka Connect? Kto zarządza workerami?
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
Co siędzieje gdy worker w Kafka Connect ulegnie awarii? Kto tym zarządza?
Jego taski zostanąprzeniesione na inny worker. Zarządza tym leader worker
Jaki jest domyślny compatibility type w Schema Registry?
backward
Przy jakim/jakich compatibility type dozwolone jest usunięcie wymaganego pola?
backward
Przy jakim/jakich compatibility type dozwolone jest dodanie opcjonalnego pola?
backward, full
Przy jakim/jakich compatibility type dozwolone jest dodanie wymaganego pola?
forward
Przy jakim/jakich compatibility type dozwolone jest usunięcie opcjonalnego pola?
forward, full
Przy backward compatibility, najpierw upgradujemy producerów czy consumerów?
Consumerów
Przy forward compatibility, najpierw upgradujemy producerów czy consumerów?
Producerów
Gdy włączone jest auto.create.topics.enable=true i tworzy sięnowy topic, jaka jest liczba partycji i replication factor?
Ustawienia brane z brokera: num.partitions i default.replication.factor
Co to jest zero-copy i dlaczego jest ważne w kafce?
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ść
Jak wygląda kompresja gdy mamy batche?
Cały batch jest kompresowany, i w tej formie jest wysyłany i zapisany na serwerze. Dopiero konsumer to dekompresuje
Jaki powinien byćbatch.size jeśli chcemy miećwysoki thoughput producera?
Tak duży jak to tylko możliwe, przy nieprzekraczaniu dostępnej pamięci.
Co oznacza unclean.leader.election.enable=true?
Liderami mogązostaćrepliki, które sąout-of-sync, więc możemy tracić wiadomości
