METHOD_0 ( ) { final java . util . concurrent . atomic . IDENT_0 IDENT_1 = new java . util . concurrent . atomic . METHOD_1 ( false ) ; final org . apache . kafka . IDENT_2 . consumer . IDENT_3 < byte [ ] , byte [ ] > consumer = new org . apache . kafka . IDENT_2 . consumer . IDENT_3 < byte [ ] , byte [ ] > ( org . apache . kafka . IDENT_2 . consumer . IDENT_4 . IDENT_5 ) { @ org . apache . kafka . streams . processor . IDENT_6 . Override public java . util . Map < java . lang . String , java . util . List < org . apache . kafka . common . IDENT_7 > > METHOD_2 ( ) { IDENT_1 . set ( true ) ; throw new org . apache . kafka . common . errors . METHOD_3 ( STRING_0 ) ; } } ; final org . apache . kafka . streams . processor . IDENT_6 . IDENT_8 IDENT_9 = new org . apache . kafka . streams . processor . IDENT_6 . METHOD_4 ( consumer , java . time . IDENT_10 . IDENT_11 , IDENT_12 , IDENT_13 ) ; IDENT_9 . METHOD_5 ( new org . apache . kafka . streams . processor . IDENT_6 . METHOD_6 ( IDENT_14 , IDENT_15 , null , Long . MAX_VALUE , true , STRING_1 , METHOD_7 ( ) ) ) ; IDENT_9 . METHOD_8 ( IDENT_16 ) ; "<AssertPlaceHolder>" ; } get ( ) { return value ; }
org . junit . Assert . assertTrue ( IDENT_1 . get ( ) )