METHOD_0 ( ) { consumer . METHOD_1 ( java . util . Collections . singletonList ( IDENT_0 ) ) ; final java . util . Map < org . apache . kafka . common . IDENT_1 , org . apache . kafka . IDENT_2 . consumer . IDENT_3 > IDENT_4 = new java . util . HashMap ( ) ; IDENT_4 . put ( new org . apache . kafka . common . METHOD_2 ( IDENT_0 . METHOD_3 ( ) , IDENT_0 . METHOD_4 ( ) ) , new org . apache . kafka . IDENT_2 . consumer . METHOD_5 ( INT_0 ) ) ; consumer . METHOD_6 ( IDENT_4 ) ; IDENT_5 . METHOD_7 ( IDENT_6 , java . util . Collections . singletonList ( new org . apache . kafka . common . METHOD_8 ( IDENT_6 , 0 , org . apache . kafka . common . Node . METHOD_9 ( ) , new org . apache . kafka . common . Node [ 0 ] , new org . apache . kafka . common . Node [ 0 ] ) ) ) ; final org . apache . kafka . streams . IDENT_7 config = METHOD_10 ( IDENT_8 ) ; final java . util . concurrent . atomic . IDENT_9 IDENT_10 = new java . util . concurrent . atomic . METHOD_11 ( false ) ; task = new org . apache . kafka . streams . processor . IDENT_11 . METHOD_12 ( IDENT_12 , IDENT_13 , IDENT_14 , consumer , IDENT_15 , config , null , IDENT_16 ) { @ org . apache . kafka . streams . processor . IDENT_11 . Override public void commit ( ) { throw new java . lang . RuntimeException ( STRING_0 ) ; } @ org . apache . kafka . streams . processor . IDENT_11 . Override void METHOD_13 ( final boolean IDENT_17 ) throws org . apache . kafka . streams . errors . IDENT_18 { IDENT_10 . set ( true ) ; } } ; task . METHOD_14 ( ) ; try { task . close ( true , false ) ; org . junit . Assert . fail ( STRING_1 ) ; } catch ( final java . lang . Exception e ) { task = null ; } "<AssertPlaceHolder>" ; } get ( ) { return value ; }
org . junit . Assert . assertTrue ( IDENT_10 . get ( ) )