METHOD_0 ( ) { config = METHOD_1 ( ) . build ( ) ; context = new io . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_2 ( config , new io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 . Builder ( config ) . build ( ) ) ; context . start ( ) ; reader = new io . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_3 ( STRING_0 , context ) ; reader . METHOD_4 ( IDENT_4 :: IDENT_5 ) ; reader . METHOD_5 ( ) ; reader . start ( ) ; java . util . List < org . apache . kafka . connect . source . IDENT_6 > records ; java . util . IDENT_7 < java . lang . String > IDENT_8 = new java . util . METHOD_6 ( ) ; java . util . METHOD_6 < java . lang . String > IDENT_9 = METHOD_7 ( STRING_1 , STRING_2 , STRING_3 , STRING_4 , STRING_5 ) ; while ( ( records = reader . METHOD_8 ( ) ) != null ) { records . METHOD_9 ( ( record ) -> { io . IDENT_0 . data . IDENT_10 . isValid ( record ) ; io . IDENT_0 . data . IDENT_10 . METHOD_10 ( record ) ; if ( ( record . value ( ) ) != null ) { IDENT_8 . add ( IDENT_11 . apply ( record ) ) ; } } ) ; } "<AssertPlaceHolder>" ; } toArray ( ) { java . util . List < io . IDENT_0 . document . IDENT_12 > values = IDENT_13 . stream ( ) . map ( io . IDENT_0 . IDENT_14 . IDENT_15 . IDENT_16 . IDENT_17 :: IDENT_18 ) . map ( IDENT_12 :: create ) . collect ( java . util . stream . IDENT_19 . toList ( ) ) ; return io . IDENT_0 . document . IDENT_20 . create ( values ) ; }
org . junit . Assert . assertArrayEquals ( IDENT_8 . toArray ( ) , IDENT_9 . toArray ( ) )