test ( ) { java . util . Properties properties = new java . util . Properties ( ) ; properties . setProperty ( STRING_0 , ( STRING_1 + ( port ) ) ) ; properties . setProperty ( STRING_2 , STRING_3 ) ; properties . setProperty ( STRING_4 , STRING_3 ) ; org . IDENT_0 . kafka . core . IDENT_1 < byte [ ] , byte [ ] > IDENT_2 = new org . IDENT_0 . kafka . core . METHOD_0 ( properties ) ; "<AssertPlaceHolder>" ; IDENT_2 . METHOD_1 ( IDENT_3 , STRING_5 . getBytes ( ) ) ; IDENT_2 . METHOD_2 ( IDENT_3 , STRING_6 . getBytes ( ) , "value" . getBytes ( ) ) ; IDENT_2 . METHOD_3 ( ) ; IDENT_2 . IDENT_4 . METHOD_4 ( null , null ) ; IDENT_2 . IDENT_4 . METHOD_4 ( null , new org . IDENT_0 . IDENT_5 . exception . METHOD_5 ( "test" ) ) ; } METHOD_6 ( java . lang . String ) { return IDENT_6 . METHOD_7 ( IDENT_3 ) ; }
org . junit . Assert . assertEquals ( IDENT_2 . METHOD_6 ( IDENT_3 ) . size ( ) , 4 )