METHOD_0 ( ) { final org . apache . kafka . IDENT_0 . consumer . IDENT_1 . IDENT_2 < org . apache . kafka . IDENT_0 . IDENT_3 > future = IDENT_4 . METHOD_1 ( node , METHOD_2 ( ) ) ; IDENT_4 . METHOD_3 ( ) ; client . METHOD_4 ( 2 ) ; java . lang . Thread IDENT_5 = new java . lang . Thread ( ) { @ org . apache . kafka . IDENT_0 . consumer . IDENT_1 . Override public void run ( ) { IDENT_4 . METHOD_3 ( ) ; } } ; IDENT_5 . start ( ) ; java . lang . Thread . sleep ( 50 ) ; java . lang . Thread IDENT_6 = new java . lang . Thread ( ) { @ org . apache . kafka . IDENT_0 . consumer . IDENT_1 . Override public void run ( ) { IDENT_4 . METHOD_5 ( future ) ; } } ; IDENT_6 . start ( ) ; java . lang . Thread . sleep ( 50 ) ; client . METHOD_6 ( METHOD_7 ( IDENT_7 . IDENT_8 ) ) ; client . METHOD_8 ( ) ; IDENT_5 . join ( ) ; IDENT_6 . join ( ) ; "<AssertPlaceHolder>" ; } METHOD_9 ( ) { return ( METHOD_10 ( ) ) && ( ! ( METHOD_11 ( ) ) ) ; }
org . junit . Assert . assertTrue ( future . METHOD_9 ( ) )