METHOD_0 ( ) { java . lang . String data = STRING_0 ; java . io . InputStream IDENT_0 = new java . io . ByteArrayInputStream ( data . getBytes ( IDENT_1 . UTF_8 ) ) ; java . lang . String IDENT_2 = STRING_1 ; java . util . Properties IDENT_3 = this . METHOD_1 ( ) ; org . apache . nifi . IDENT_4 . kafka . IDENT_5 IDENT_6 = new org . apache . nifi . IDENT_4 . kafka . METHOD_2 ( IDENT_3 , mock ( org . apache . nifi . logging . IDENT_7 . class ) ) ; org . apache . nifi . IDENT_4 . kafka . IDENT_8 IDENT_9 = new org . apache . nifi . IDENT_4 . kafka . METHOD_3 ( IDENT_0 , IDENT_2 ) ; IDENT_6 . METHOD_4 ( IDENT_9 ) ; IDENT_6 . close ( ) ; kafka . consumer . IDENT_10 < byte [ ] , byte [ ] > IDENT_11 = this . METHOD_5 ( IDENT_2 ) ; java . lang . String r = new java . lang . String ( IDENT_11 . next ( ) . message ( ) , java . nio . IDENT_12 . IDENT_1 . UTF_8 ) ; "<AssertPlaceHolder>" ; } next ( ) { try { if ( METHOD_6 ( ) ) { java . sql . ResultSet rs = METHOD_7 ( ) ; final org . apache . nifi . serialization . record . IDENT_13 record = METHOD_8 ( rs ) ; if ( ( IDENT_14 ) != null ) { IDENT_14 . METHOD_9 ( rs ) ; } METHOD_10 ( rs . next ( ) ) ; return record ; } else { return null ; } } catch ( final java . sql . IDENT_15 e ) { throw new java . io . IOException ( STRING_2 , e ) ; } }
org . junit . Assert . assertEquals ( data , r )