e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 3 3 2 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 0 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 4 3 4 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 0 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 4 3 5 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 0 0 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 5 3 7 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 0 0 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 5 3 9 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 1 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 6 4 1 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 1 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 6 4 2 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 2 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 7 4 5 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 2 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 7 4 7 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 3 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 8 5 0 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 3 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 8 5 2 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 4 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 9 5 4 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 4 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 4 , 9 5 5 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 5 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 0 5 7 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 5 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 0 5 9 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 6 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 1 6 1 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 6 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 1 6 3 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 7 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 2 6 5 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 7 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 2 6 7 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 8 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 3 6 9 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 8 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 3 7 0 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 1 9 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 4 7 3 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 1 9 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 4 7 4 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 2 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 5 7 6 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 2 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 5 7 7 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 2 0 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 6 8 0 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 2 0 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 6 8 1 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 2 1 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 7 8 4 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 2 1 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 7 8 6 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 2 2 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 8 8 8 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 2 2 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 8 8 9 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 2 3 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 9 9 1 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 2 3 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 5 , 9 9 3 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 2 4 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 6 , 0 9 5 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 2 4 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 6 , 0 9 6 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 2 5 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 6 , 1 9 8 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 2 5 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 6 , 2 0 0 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 2 6 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 6 , 3 0 2 [ D E B U G ] U p d a t i n g o f f s e t o n K a f k a w i t h k e y / d a t a / s o u r c e / 2 t o / d a t a / s o u r c e / 2 / 2 6 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 6 , 3 0 5 [ D E B U G ] P r o c e s s i n g / d a t a / s o u r c e / 2 / 2 7 e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 6 , 3 2 0 [ W A R N ] S k i p p i n g o f f s e t u p d a t e f o r d u e t o f a i l u r e i n p r o c e s s i n g e x a m p l e - 2 _ 1 | * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * e x a m p l e - 2 _ 1 | F i n i s h e d t h e i t e r a t i o n 2 e x a m p l e - 2 _ 1 | * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * e x a m p l e - 2 _ 1 | * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * e x a m p l e - 2 _ 1 | R u n n i n g t h e i t e r a t i o n 3 o f 5 w i t h a b a t c h o f 2 5 f i l e s e x a m p l e - 2 _ 1 | * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * e x a m p l e - 2 _ 1 | W A R N I N G : s u n . r e f l e c t . R e f l e c t i o n . g e t C a l l e r C l a s s i s n o t s u p p o r t e d . T h i s w i l l i m p a c t p e r f o r m a n c e . e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 9 , 3 3 4 [ I N F O ] S t a r t i n g t h e c l u s t e r s e r v i c e e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 9 , 3 5 7 [ D E B U G ] I n i t i a l i z i n g t h e K a f k a r e s u m e s t r a t e g y e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 9 , 4 4 1 [ D E B U G ] C r e a t i n g a l i s t e n e r / r e f r e s h e r e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 9 , 6 0 4 [ I N F O ] S t a r t i n g t h e r e s u m a b l e s t r a t e g y : C l u s t e r A w a r e K a f k a F i l e S e t R e s u m e S t r a t e g y e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 9 , 6 0 4 [ I N F O ] S t a r t i n g t h e k a f k a r e s u m e s t r a t e g y e x a m p l e - 2 _ 1 | 2 0 2 2 - 0 3 - 2 1 1 1 : 3 4 : 3 9 , 6 0 4 [ D E B U G ] L o a d i n g r e c o r d s f r o m t o p i c d i r - o f f s e t s