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_3 5 ) ; IDENT_0 . put ( STRING_4 , STRING_3 ) ; IDENT_0 . put ( STRING_3 3 , STRING_3 ) ; IDENT_0 . put ( IDENT_4 . IDENT_5 , STRING_5 ) ; IDENT_0 . put ( IDENT_6 . IDENT_7 , STRING_6 ) ; IDENT_0 . put ( IDENT_6 . IDENT_8 , org . apache . IDENT_1 . authorization . kafka . IDENT_2 . IDENT_3 . IDENT_9 ) ; IDENT_0 . put ( IDENT_6 . IDENT_10 , STRING_7 ) ; IDENT_0 . put ( IDENT_6 . IDENT_11 , STRING_3 6 ) ; IDENT_0 . put ( IDENT_6 . IDENT_12 , org . apache . IDENT_1 . authorization . kafka . IDENT_2 . IDENT_3 . IDENT_13 ) ; IDENT_0 . put ( IDENT_6 . IDENT_14 , STRING_3 0 ) ; final org . apache . kafka . IDENT_15 . IDENT_16 . IDENT_17 < java . lang . String , java . lang . String > IDENT_16 = new org . apache . kafka . IDENT_15 . IDENT_16 . METHOD_1 ( IDENT_0 ) ; java . util . concurrent . IDENT_18 < org . apache . kafka . IDENT_15 . IDENT_16 . IDENT_19 > record = IDENT_16 . METHOD_2 ( new org . apache . kafka . IDENT_15 . IDENT_16 . IDENT_20 < java . lang . String , java . lang . String > ( "test" , STRING_3 1 , STRING_8 ) ) ; IDENT_16 . METHOD_3 ( ) ; record . get ( ) ; try { record = IDENT_16 . METHOD_2 ( new org . apache . kafka . IDENT_15 . IDENT_16 . IDENT_20 < java . lang . String , java . lang . String > ( STRING_3 2 , STRING_3 1 , STRING_8 ) ) ; IDENT_16 . METHOD_3 ( ) ; record . get ( ) ; } catch ( java . lang . Exception ex ) { "<AssertPlaceHolder>" ; } IDENT_16 . close ( ) ; } getMessage ( ) { return this . message ; }
org . junit . Assert . assertTrue ( ex . getMessage ( ) . contains ( STRING_3 4 ) )