Piszę moduł, który jest zapisywalnym strumieniem. Chcę wdrożyć interfejs rur dla moich użytkowników. Jeśli wystąpi jakikolwiek błąd, muszę wstrzymać czytelny strumień i wyemitować zdarzenie błędu. Nas
Korzystam z sterownika datastax java 3.1.0, aby połączyć się z kelnera i moją wersją kelnerki jest 2.0.10. Piszę asynchronicznie z konsekwencją QUORUM. private final ExecutorService executorService =