METHOD_0 ( ) { final java . lang . String IDENT_0 = STRING_0 ; IDENT_1 . METHOD_1 ( METHOD_2 ( IDENT_2 ) , IDENT_3 ) ; client . METHOD_3 ( METHOD_4 ( node , IDENT_4 . IDENT_5 ) ) ; IDENT_6 . METHOD_5 ( time . METHOD_6 ( Long . MAX_VALUE ) ) ; client . METHOD_3 ( METHOD_7 ( ( - 1 ) , IDENT_0 , STRING_1 , IDENT_4 . IDENT_7 ) ) ; IDENT_6 . METHOD_8 ( time . METHOD_6 ( 0 ) ) ; final java . util . concurrent . atomic . IDENT_8 IDENT_9 = new java . util . concurrent . atomic . METHOD_9 ( false ) ; client . METHOD_3 ( new org . apache . kafka . IDENT_10 . IDENT_11 . METHOD_10 ( ) { @ org . apache . kafka . IDENT_10 . consumer . IDENT_12 . Override public boolean matches ( org . apache . kafka . common . IDENT_13 . IDENT_14 body ) { IDENT_9 . set ( true ) ; org . apache . kafka . common . IDENT_13 . IDENT_15 IDENT_16 = ( ( org . apache . kafka . common . IDENT_13 . IDENT_15 ) ( body ) ) ; return IDENT_16 . data ( ) . METHOD_11 ( ) . equals ( IDENT_0 ) ; } } , new org . apache . kafka . common . IDENT_13 . METHOD_12 ( new org . apache . kafka . common . message . METHOD_13 ( ) . METHOD_14 ( IDENT_4 . IDENT_5 . code ( ) ) ) ) ; IDENT_6 . METHOD_15 ( ) ; "<AssertPlaceHolder>" ; } get ( ) { return value ; }
org . junit . Assert . assertTrue ( IDENT_9 . get ( ) )