METHOD_0 ( ) { METHOD_1 ( IDENT_0 ) ; java . util . concurrent . IDENT_1 IDENT_2 = new java . util . concurrent . METHOD_2 ( 1 ) ; com . github . IDENT_3 . kafka . IDENT_4 properties = new com . github . IDENT_3 . kafka . METHOD_3 ( ) ; properties . METHOD_4 ( METHOD_3 . IDENT_5 , true ) ; com . github . IDENT_3 . kafka . connection . IDENT_6 IDENT_7 = new com . github . IDENT_3 . kafka . connection . METHOD_5 ( STRING_0 , IDENT_8 , 0 , IDENT_0 , new io . netty . channel . nio . METHOD_6 ( ) , properties ) ; IDENT_7 . connect ( ) . sync ( ) ; IDENT_7 . METHOD_7 ( METHOD_8 ( "1" . getBytes ( ) ) , 0 , METHOD_8 ( com . github . IDENT_3 . kafka . IDENT_9 . IDENT_10 . getBytes ( ) ) ) ; final kafka . consumer . IDENT_11 < byte [ ] , byte [ ] > stream = METHOD_9 ( IDENT_0 ) . get ( 0 ) ; final kafka . consumer . IDENT_12 < byte [ ] , byte [ ] > messages = stream . iterator ( ) ; "<AssertPlaceHolder>" ; IDENT_7 . METHOD_10 ( ) ; } get ( com . github . IDENT_3 . kafka . IDENT_13 ) { java . util . IDENT_14 . METHOD_11 ( property , STRING_1 ) ; IDENT_15 v = ( ( IDENT_15 ) ( properties . get ( property ) ) ) ; return v == null ? property . METHOD_12 ( ) : v ; }
org . junit . Assert . assertThat ( new java . lang . String ( messages . next ( ) . message ( ) ) , org . hamcrest . CoreMatchers . is ( com . github . IDENT_3 . kafka . IDENT_9 . IDENT_10 ) )