METHOD_0 ( ) { final int IDENT_0 = 2 ; final java . util . concurrent . atomic . IDENT_1 IDENT_2 = new java . util . concurrent . atomic . METHOD_1 ( 0 ) ; consumer = new org . apache . kafka . IDENT_3 . consumer . IDENT_4 < byte [ ] , byte [ ] > ( org . apache . kafka . IDENT_3 . consumer . IDENT_5 . IDENT_6 ) { @ org . apache . kafka . streams . processor . IDENT_7 . Override public MOD_0 java . util . Map < org . apache . kafka . common . IDENT_8 , java . lang . Long > METHOD_2 ( final java . util . Collection < org . apache . kafka . common . IDENT_8 > IDENT_9 ) { IDENT_2 . METHOD_3 ( ) ; throw new org . apache . kafka . common . errors . METHOD_4 ( ) ; } } ; IDENT_10 = new org . apache . kafka . streams . METHOD_5 ( new java . util . Properties ( ) { { put ( METHOD_5 . IDENT_11 , STRING_0 ) ; put ( METHOD_5 . IDENT_12 , STRING_1 ) ; put ( METHOD_5 . IDENT_13 , org . apache . kafka . test . TestUtils . METHOD_6 ( ) . getPath ( ) ) ; put ( METHOD_5 . IDENT_14 , IDENT_0 ) ; } } ) ; try { new org . apache . kafka . streams . processor . IDENT_7 . METHOD_7 ( new org . apache . kafka . common . utils . METHOD_8 ( STRING_2 ) , IDENT_15 , consumer , IDENT_16 , IDENT_17 , IDENT_10 ) ; } catch ( final org . apache . kafka . streams . errors . IDENT_18 expected ) { "<AssertPlaceHolder>" ; } } get ( ) { return value ; }
org . junit . Assert . assertEquals ( IDENT_2 . get ( ) , IDENT_0 )