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