Zapisujemy nasze myśli i tworzymy niewielkie projekty open source. Tutaj żyje jedno i drugie. Rozejrzyj się — i daj nam znać, co o tym sądzisz.
Nadchodzi moduł replikacji: mechanika ISR, high watermark, acks=all i min.insync.replicas, wybór lidera oraz to, co naprawdę tracimy przy nieczystym wyborze. Dwanaście scenariuszy o gwarancjach, z których Kafka słynie.
Grupy konsumentów, strategie przydziału partycji, statyczne członkostwo i dwa timeouty decydujące o tym, kiedy członek grupy znika. Dziesięć nowych scenariuszy, dzięki którym rebalans — najczęściej źle rozumiany moment w Kafce — można obejrzeć, zamiast zgadywać.
Symulator Kafki v1.1 dodaje dziesięć scenariuszy obejmujących batchowanie producenta, partycjonowanie, kompresję, backpressure, ponawianie prób i idempotentność.
KIP-714 pozwala klientom Kafki wysyłać własne metryki do brokerów przez OTLP. monedula-metrics-reporter przekazuje teraz również te metryki, obok metryk broker SPI i Yammer.
Najważniejsze lekcje płynące z Kafki kryją się w przejściach: przed i po awarii brokera, przed i po skurczeniu się ISR. Zbudowaliśmy działający w przeglądarce symulator, dzięki któremu możesz bezpiecznie zepsuć klaster i zobaczyć dokładnie, dlaczego reaguje tak, a nie inaczej.
Bezpieczne, audytowalne narzędzie wiersza poleceń do konwersji ACL Apache Kafka na powiązania ról Confluent RBAC. Plany są opatrywane sumą kontrolną, a efektywny dostęp jest weryfikowany, zanim cokolwiek zostanie zastosowane.
Wtyczka Kafka MetricsReporter, która wysyła metryki brokera i klienta przez OTLP do collectora OpenTelemetry. Asynchroniczna i odporna na awarie — awarie collectora nigdy nie blokują Kafki.