La ce întrebări despre Kafka să mă aștept la interviu?

Știi deja că Kafka este un jurnal distribuit și te îngrijorează că intervievatorul va coborî cu un nivel mai adânc decât utilizarea ta zilnică. Exact în această direcție merg întrebările, așa că secțiunea prezintă vocabularul în ordinea urmată de obicei de intervievatori și indică întrebarea suplimentară din spatele fiecărui termen.

• Subiecte și partiții. Un subiect este împărțit în partiții, fiecare fiind un jurnal ordonat în care datele sunt doar adăugate. Întrebare suplimentară: de ce Kafka scalează scrierile adăugând partiții, în loc să accelereze un singur jurnal?
• Offseturi. Poziția unui consumator într-o partiție. Întrebare suplimentară: cine stochează offseturile confirmate și ce se întâmplă dacă un consumator se oprește înainte de confirmare?
• Grupuri de consumatori. Consumatorii dintr-un grup împart partițiile unui subiect, iar o partiție revine simultan cel mult unui consumator din grup. Întrebare suplimentară: ce se întâmplă cu debitul dacă grupul are mai mulți consumatori decât partiții?
• Brokeri și controlerul. Brokerii stochează partiții; controlerul gestionează alegerea liderilor și metadatele. Întrebare suplimentară: ce s-a schimbat când Kafka a mutat metadatele din ZooKeeper în KRaft?
• Producători și chei. Un mesaj cu o cheie ajunge într-o partiție aleasă prin calcularea hashului cheii; un mesaj fără cheie este distribuit între partiții. Întrebare suplimentară: care dintre aceste variante păstrează ordinea evenimentelor unui client?

Răspunde explicând mecanismul, nu sloganul. Să spui că partițiile oferă paralelism este doar cerința minimă; explicația că ordinea există numai într-o partiție și că, prin urmare, cheia stabilește domeniul de ordonare este răspunsul care te duce în etapa următoare.

Acesta este nivelul la care majoritatea candidaților pierd puncte, deoarece termenii sunt simpli, dar compromisurile nu. Așteaptă-te ca intervievatorul să enunțe o garanție și să îți ceară să o construiești prin configurări.

• Cel mult o dată față de cel puțin o dată. Confirmă offsetul înainte de procesare și poți pierde un mesaj; procesează mai întâi și confirmă după, iar mesajul poate fi procesat de două ori. Spune ce tip de defecțiune tolerează fiecare ordine și pe care o preferă sistemul tău.
• Producători idempotenți și exact o dată. Un producător idempotent elimină încercările duplicate dintr-o partiție; tranzacțiile extind acest comportament între partiții și asupra offseturilor consumatorilor într-o buclă consumare-transformare-producere. Fii pregătit să spui ce nu acoperă livrarea exact o dată: o scriere într-o bază de date din aval, în afara tranzacției, rămâne responsabilitatea ta.
• acks, factorul de replicare și replicile sincronizate. acks=all așteaptă setul de replici sincronizate; min.insync.replicas stabilește cât de mult se poate micșora acel set înainte ca scrierile să fie refuzate. Intervievatorii întreabă adesea ce sacrifici aici pentru durabilitate: latența și disponibilitatea când un broker se oprește.
• Retenție și compactare. Retenția bazată pe timp sau dimensiune șterge segmentele vechi; compactarea jurnalului păstrează cea mai recentă înregistrare pentru fiecare cheie. Întrebare suplimentară: care variantă susține jurnalul de modificări al unui depozit cheie-valoare și de ce?
• Reechilibrare. Când un consumator intră sau iese, partițiile sunt realocate. Întrebare suplimentară: cum afectează o reechilibrare îndelungată un serviciu sensibil la latență și cum reduc impactul reechilibrarea cooperativă și apartenența statică?

Un obicei util: pentru fiecare setare menționată, spune ce defecțiune previne și ce cost adaugă. Această structură răspunde dintr-o suflare atât întrebării, cât și celei suplimentare.

În interviurile pentru roluri avansate, definițiile sunt înlocuite cu un scenariu, iar intervievatorii urmăresc cum raționezi. Un exemplu obișnuit: unui inginer backend intervievat pentru un rol de platformă la o companie de plăți i se cere să proiecteze un flux de evenimente în care fiecare tranzacție a unui cont trebuie procesată în ordine, debitul trebuie să crească odată cu traficul, iar oprirea unui broker nu trebuie să ducă la pierderea datelor. Un răspuns solid folosește identificatorul contului drept cheie pentru ca evenimentele aceluiași cont să ajungă în aceeași partiție, dimensionează partițiile pentru vârful estimat și lasă spațiu pentru creștere, configurează replicarea și acks=all pentru durabilitate și explică modul în care consumatorii confirmă offseturile astfel încât o oprire să determine reluarea procesării, nu omiterea datelor.

Alte scenarii recurente: un consumator care rămâne în urmă și modul în care detectezi decalajul și recuperezi; un subiect al cărui număr de partiții îl regreți și motivul pentru care repartiționarea afectează ordinea după cheie; un mesaj problematic care oprește consumatorul și modelul cozii de mesaje eșuate care îl izolează; modificările de schemă între producători și consumatori și avantajele oferite de un registru de scheme. Intervievatorul nu caută o singură arhitectură corectă. Vrea să numești constrângerea, să alegi un mecanism și să exprimi clar compromisul.

Exersează cu voce tare înainte de interviu, nu te limita la a citi. Modul de practică de pe pagina de interviu simulat este conceput pentru repetarea scenariilor cu un intervievator AI care insistă asupra întrebărilor suplimentare, iar colecția mai amplă de întrebări pe roluri și subiecte se află la întrebări de interviu după rol și subiect.

Într-o etapă conversațională, da, în limite oneste. Aplicația desktop nativă SubcueAI pentru macOS și Windows captează sunetul intervievatorului și microfonul tău și afișează sugestii scurte de răspuns într-o suprapunere locală. Astfel, când intervievatorul întreabă împotriva cărui risc protejează min.insync.replicas, mecanismul apare pe ecran în timp ce îl explici în propriile cuvinte. Extensia de browser face același lucru pentru apelurile din filele browserului, captând numai sunetul filei întâlnirii. Niciuna nu adaugă un bot la apel și nici nu introduce ceva în pagina întâlnirii; instrucțiunile de configurare se află pe pagina de tutorial.

Limitele contează mai mult decât prezentarea produsului. Un test de programare supravegheat, un ecran înregistrat sau un laptop administrat de companie nu intră în domeniul de utilizare, iar un exercițiu de programare în direct, în care trebuie să implementezi un consumator sub observație, este propria ta muncă. Asistentul este cel mai util pentru întrebările de mai sus despre terminologie și compromisuri și cel mai puțin util pentru orice trebuie introdus într-o platformă de evaluare. Înainte de a te baza pe el, oferă-i CV-ul tău, astfel încât sugestiile să reflecte munca pe care ai făcut-o efectiv cu Kafka; profilul respectiv se află în instrumentul pentru crearea CV-ului.