Golang

Selgitage manual commit mõistet Kafka-s

Kuidas andmed andmebaasis salvestatakse?

Kas sul on mulle küsimusi?

Mis vahe on HAVING ja WHERE vahel?

Miks meil on vaja katkestada kontekst struktuuris? Miks lõpetada töötajad? Me tahame katkestada Stop meetodi.

Kas kirjutad oma praeguses töös palju asünkroonset koodi?

Mis juhtub puhvris, kui kirjutamise goroutines on blokeeritud?

Mida juhtuks, kui teenus kukuks ja ei loeks Kafka sõnumeid?

Sa lisad WaitGroupi, milleks?

Kuidas teha andmestruktuur üldine (töötav iga väärtusetüübiga) Go keeles?

Kuidas töötab consumer committed offset erinevates režiimides?

Kombineeritud indeksid – mida esmalt panna: võrdus või vahemik?

Virtuaalmasina ja konteineri vahe

Kuidas erineb RIGHT JOIN teistest JOIN-idest? Mis on CROSS JOIN?

Räägi mulle CQRS-st

Milliseid teisi protsentile kasutisite?

Miks valisite Kafka teiste sõidukite (RabbitMQ, NATS) asemel?

// Kirjutage asünkroonsete ülesannete töötleja raamatukoguna // Klient edastab objekti (Task) andmetega ülesande täitmiseks, // meie näites kasutame tühja struktuuri. // Töötleja saab samaaegselt töödelda mitte rohkem kui N ülesannet, // ja mitte rohkem kui X ülesannet võib olla järjekorras töötlemiseks. // Kui järjekorras pole kohta, tagastame kohe vea kliendile. // Ülesanne võetakse töötlemiseks, kui on vabad töötlejad. // Simuleerime töötlemise kestust kasutades time.Sleep(5*time.Second). // Kui üks ülesanne lõpeb, võtame järgmise järjekorrast. // Kui järjekord on tühi, ootame uusi ülesandeid klientidelt. // Tärniga: laiendage Task struktuuri ja saage ülesannete staatuseid eraldi päringuga.

Kuidas lisada kontekst Meetodi Stop, et saaks katkestada ooteaega ülesannete täitmiseks koos ajapiiranguga?

Miks meil on selle ülesande jaoks vaja WaitGroup?