METHOD_0 ( ) { java . util . Properties IDENT_0 = new java . util . Properties ( ) ; IDENT_0 . put ( STRING_0 , ( STRING_1 + ( org . apache . IDENT_1 . authorization . kafka . IDENT_2 . IDENT_3 . port ) ) ) ; IDENT_0 . put ( STRING_2 , STRING_0 3 ) ; IDENT_0 . put ( STRING_3 , STRING_4 ) ; IDENT_0 . put ( STRING_0 1 , STRING_4 ) ; IDENT_0 . put ( IDENT_4 . IDENT_5 , STRING_0 5 ) ; IDENT_0 . put ( STRING_0 4 , STRING_5 ) ; IDENT_0 . put ( STRING_0 0 , STRING_6 ) ; final org . apache . kafka . IDENT_6 . IDENT_7 . IDENT_8 < java . lang . String , java . lang . String > IDENT_7 = new org . apache . kafka . IDENT_6 . IDENT_7 . METHOD_1 ( IDENT_0 ) ; try { java . util . concurrent . IDENT_9 < org . apache . kafka . IDENT_6 . IDENT_7 . IDENT_10 > record = IDENT_7 . METHOD_2 ( new org . apache . kafka . IDENT_6 . IDENT_7 . IDENT_11 < java . lang . String , java . lang . String > ( STRING_7 , STRING_8 , STRING_9 ) ) ; IDENT_7 . METHOD_3 ( ) ; record . get ( ) ; } catch ( java . lang . Exception ex ) { "<AssertPlaceHolder>" ; } IDENT_7 . close ( ) ; } getMessage ( ) { return this . message ; }
org . junit . Assert . assertTrue ( ex . getMessage ( ) . contains ( STRING_0 2 ) )