METHOD_0 ( ) { final org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 IDENT_2 = new org . apache . kafka . streams . processor . IDENT_0 . METHOD_1 ( IDENT_3 , java . util . Collections . METHOD_2 ( IDENT_4 ) , false , IDENT_5 , java . util . Collections . METHOD_3 ( IDENT_6 , IDENT_7 ) , IDENT_8 , false , IDENT_9 ) ; final java . util . concurrent . atomic . IDENT_10 IDENT_11 = new java . util . concurrent . atomic . METHOD_4 ( false ) ; final org . apache . kafka . test . IDENT_12 IDENT_13 = new org . apache . kafka . test . METHOD_5 ( IDENT_6 , true ) { @ org . apache . kafka . streams . processor . IDENT_0 . Override public void METHOD_6 ( ) { throw new java . lang . RuntimeException ( STRING_0 ) ; } } ; final org . apache . kafka . test . METHOD_5 IDENT_14 = new org . apache . kafka . test . METHOD_5 ( ( ( IDENT_6 ) + "2" ) , true ) { @ org . apache . kafka . streams . processor . IDENT_0 . Override public void METHOD_6 ( ) { IDENT_11 . set ( true ) ; } } ; IDENT_2 . METHOD_7 ( IDENT_13 , IDENT_13 . IDENT_15 ) ; IDENT_2 . METHOD_7 ( IDENT_14 , IDENT_14 . IDENT_15 ) ; try { IDENT_2 . METHOD_6 ( ) ; } catch ( final org . apache . kafka . streams . errors . IDENT_16 expected ) { } "<AssertPlaceHolder>" ; } get ( ) { return value ; }
org . junit . Assert . assertTrue ( IDENT_11 . get ( ) )