METHOD_0 ( ) { final org . apache . kafka . common . utils . IDENT_0 IDENT_1 = org . apache . kafka . common . utils . IDENT_0 . METHOD_1 ( key . getBytes ( ) ) ; final org . apache . kafka . streams . IDENT_2 . IDENT_3 < org . apache . kafka . common . utils . IDENT_0 > IDENT_4 = new org . apache . kafka . streams . IDENT_2 . METHOD_2 ( IDENT_1 , IDENT_5 ) ; final org . apache . kafka . common . utils . IDENT_0 IDENT_6 = org . apache . kafka . streams . state . IDENT_7 . IDENT_8 . METHOD_3 ( IDENT_4 ) ; "<AssertPlaceHolder>" ; } from ( org . apache . kafka . common . utils . IDENT_0 ) { final byte [ ] IDENT_9 = IDENT_1 . get ( ) ; final org . apache . kafka . streams . IDENT_2 . IDENT_10 IDENT_5 = org . apache . kafka . streams . state . IDENT_7 . IDENT_8 . METHOD_4 ( IDENT_9 ) ; return new org . apache . kafka . streams . IDENT_2 . METHOD_2 ( org . apache . kafka . common . utils . IDENT_0 . METHOD_1 ( org . apache . kafka . streams . state . IDENT_7 . IDENT_8 . METHOD_5 ( IDENT_9 ) ) , IDENT_5 ) ; }
org . junit . Assert . assertEquals ( IDENT_4 , org . apache . kafka . streams . state . IDENT_7 . IDENT_8 . from ( IDENT_6 ) )