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