METHOD_0 ( ) { com . IDENT_0 . IDENT_1 . kafka . test . IDENT_2 < com . IDENT_0 . IDENT_1 . api . IDENT_3 > future = new com . IDENT_0 . IDENT_1 . kafka . test . METHOD_1 ( ) ; com . IDENT_0 . IDENT_1 . api . server . IDENT_4 handler = ( request ) -> { future . METHOD_2 ( request ) ; return com . IDENT_0 . IDENT_1 . api . Response . METHOD_3 ( ) . METHOD_4 ( new com . IDENT_0 . IDENT_1 . kafka . fixture . METHOD_5 ( STRING_0 ) ) . METHOD_6 ( request . METHOD_7 ( ) ) . METHOD_8 ( true ) . METHOD_9 ( ) ; } ; com . IDENT_0 . IDENT_1 . kafka . test . IDENT_5 . IDENT_6 . METHOD_10 ( handler ) ; com . IDENT_0 . IDENT_1 . api . IDENT_3 request = com . IDENT_0 . IDENT_1 . api . IDENT_3 . METHOD_3 ( ) . METHOD_4 ( new com . IDENT_0 . IDENT_1 . kafka . fixture . METHOD_11 ( STRING_1 ) ) . METHOD_12 ( true ) . build ( ) ; com . IDENT_0 . IDENT_1 . kafka . test . IDENT_5 . client . METHOD_13 ( request ) ; com . IDENT_0 . IDENT_1 . api . IDENT_3 IDENT_7 = future . get ( 10 , TimeUnit . IDENT_8 ) ; "<AssertPlaceHolder>" ; } METHOD_13 ( com . IDENT_0 . IDENT_1 . api . IDENT_3 ) { if ( ( request . METHOD_14 ( ) ) == null ) { throw new java . lang . METHOD_15 ( STRING_2 ) ; } request . METHOD_16 ( IDENT_9 ) ; IDENT_10 . METHOD_17 ( new org . apache . kafka . IDENT_11 . IDENT_12 . METHOD_18 ( IDENT_13 , request . METHOD_19 ( ) , request ) , ( IDENT_14 , e ) -> { if ( e != null ) { com . IDENT_0 . IDENT_1 . kafka . client . IDENT_15 . logger . error ( STRING_3 , e ) ; IDENT_16 . METHOD_20 ( request . METHOD_7 ( ) ) ; } com . IDENT_0 . IDENT_1 . kafka . client . IDENT_15 . logger . debug ( STRING_4 , request . METHOD_7 ( ) ) ; } ) ; }
org . junit . Assert . assertEquals ( request , IDENT_7 )