2015-08-18 22 views
10

planujemy wykorzystać Kafkę jako główny komponent w naszej hurtowni danych, biorąc pod uwagę, że producent jest w stanie obsługiwać transakcje (w skrócie: wycofywanie zmian i zatwierdzenia).Czy Apache Kafka jest w stanie obsłużyć transakcje?

Kiedy googlowania Kafka + Transactions znaleźć wiele teoretycznych przemyśleń na temat możliwości jak Kafka mógł transakcje handle ale w tej chwili nie widzę żadnej funkcji w Java API, który obsługuje zobowiązuje i wycofywanie zmian dla producent.

Czy ktoś ma pewne doświadczenia z transakcjami i Kafką i może mi podpowiedzieć?

+0

czy mógłbyś być bardziej konkretny w części producenta? co dokładnie próbujesz osiągnąć? – user2720864

+0

Po prostu powiedziałem: Chcę przekazać wiadomość do tematu za pośrednictwem interfejsu API producenta Java i sprawdzić, czy działa. Jeśli id ​​zadziałał, chciałbym przekazać wiadomość do tematu. Podobnie jak w JMS lub XA w popularnych relacyjnych systemach baz danych. – padmalcom

+0

"Sprawdź, czy to działa" - API producenta może oddzwonić z powodzeniem lub niepowodzeniem. To powinno wystarczyć do przechowywania danych: jeśli Kafka nie jest twoim systemem zapisu, możesz zawsze * ponowić * wysłanie do Kafki. Czy możesz dokładniej określić, co próbujesz zrobić? –

Odpowiedz

1

Myślę, że to, czego szukasz, to tak zwane przekazy transakcyjne w Kafce, gdzie producenci są w stanie stworzyć sesję (aka transakcyjną) i wysyłać wiadomości w ramach sesji. W związku z tym może zdecydować o zatwierdzeniu/anulowaniu transakcji.

[Źródło]: Proszę przeczytać wiki szczegółów

+10

Cześć, tak, widziałem wiki, ale to jest - o ile mogę to ocenić - tylko propozycja przyszłej implementacji. Moje pytanie brzmi, czy w obecnej wersji można już obsługiwać sesje transakcyjne. – padmalcom

Powiązane problemy