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