METHOD_0 ( ) { when ( consumer . METHOD_1 ( METHOD_2 ( ) ) ) . thenReturn ( new org . apache . kafka . IDENT_0 . consumer . METHOD_3 ( java . util . Collections . < org . apache . kafka . common . IDENT_1 , java . util . List < org . apache . kafka . IDENT_0 . consumer . IDENT_2 < java . lang . String , java . lang . String > > > METHOD_4 ( ) ) ) ; when ( consumer . METHOD_5 ( java . util . Collections . singletonList ( IDENT_3 ) ) ) . thenReturn ( java . util . Collections . METHOD_6 ( IDENT_3 , IDENT_4 ) ) ; "<AssertPlaceHolder>" ; } METHOD_7 ( ) { if ( ( key ) == null ) { key = new org . apache . hadoop . io . METHOD_8 ( ) ; } key . set ( pos ) ; if ( ( value ) == null ) { value = new org . apache . hadoop . io . METHOD_9 ( ) ; } if ( ( pos ) >= ( end ) ) { key = null ; value = null ; org . apache . IDENT_5 . io . text . IDENT_6 . IDENT_7 . LOGGER . info ( STRING_0 , IDENT_8 ) ; close ( ) ; return false ; } final int IDENT_9 = IDENT_10 . METHOD_10 ( value ) ; if ( IDENT_9 == 0 ) { org . apache . IDENT_5 . io . text . IDENT_6 . IDENT_7 . LOGGER . info ( STRING_1 , IDENT_8 ) ; return false ; } pos += IDENT_9 ; ( IDENT_8 ) ++ ; return true ; }
org . junit . Assert . assertThat ( reader . METHOD_7 ( ) , org . hamcrest . core . Is . is ( false ) )