Jaka jest różnica między najwcześniejszymi i najnowszymi wartościami przesunięcia Kafki

producer wysyła wiadomości 1, 2, 3, 4

consumer odbiera wiadomości 1, 2, 3, 4

consumer awarie / rozłączenia

producer wysyła wiadomości 5, 6, 7

consumer wraca i powinien otrzymywać wiadomości zaczynające się od 5 zamiast 7

Dla tego rodzaju wyniku, jaką wartość {[5] } muszę użyć i jakie są inne zmiany / konfiguracje, które muszę zrobić

Author: Sat, 2018-01-18
Source

1 answers

Gdy konsument dołączy do grupy konsumentów, pobierze ostatni popełniony offset, więc uruchomi się ponownie, aby odczytać od 5, 6, 7, jeśli przed awarią popełnił ostatni offset (so 4). Wartości earliest i latest dla właściwości auto.offset.reset są używane, gdy konsument zaczyna, ale nie ma zadanego przesunięcia dla przypisanej partycji. W tym przypadku możesz wybrać, czy chcesz ponownie przeczytać wszystkie wiadomości Od początku (najwcześniej) lub tuż po ostatnim (najnowszym).

 47
Author: ppatierno,
Warning: date(): Invalid date.timezone value 'Europe/Kyiv', we selected the timezone 'UTC' for now. in /var/www/agent_stack/data/www/doraprojects.net/template/agent.layouts/content.php on line 54
2018-01-18 12:01:10