METHOD_0 ( ) { final org . apache . kafka . common . IDENT_0 IDENT_1 = new org . apache . kafka . common . METHOD_1 ( STRING_0 , 2 ) ; IDENT_2 . put ( IDENT_3 , org . apache . kafka . common . utils . Utils . METHOD_2 ( IDENT_4 , IDENT_5 , IDENT_1 ) ) ; IDENT_6 . METHOD_3 ( IDENT_2 , cluster . METHOD_4 ( java . util . Collections . METHOD_5 ( IDENT_1 , new org . apache . kafka . common . METHOD_6 ( STRING_0 , 2 , null , null , null ) ) ) ) ; final org . apache . kafka . streams . state . IDENT_7 expected = new org . apache . kafka . streams . state . METHOD_7 ( IDENT_3 , org . apache . kafka . common . utils . Utils . METHOD_2 ( STRING_1 , STRING_2 , STRING_3 , STRING_4 ) , org . apache . kafka . common . utils . Utils . METHOD_2 ( IDENT_4 , IDENT_5 , IDENT_1 ) ) ; final org . apache . kafka . streams . state . METHOD_7 actual = IDENT_6 . METHOD_8 ( STRING_4 , STRING_5 , new org . apache . kafka . streams . processor . IDENT_8 < java . lang . String , java . lang . Object > ( ) { @ org . apache . kafka . streams . processor . IDENT_9 . Override public org . apache . kafka . streams . processor . IDENT_9 . Integer METHOD_9 ( final java . lang . String IDENT_10 , final java . lang . String key , final java . lang . Object value , final int IDENT_11 ) { return 2 ; } } ) ; "<AssertPlaceHolder>" ; } METHOD_9 ( org . apache . kafka . IDENT_12 . IDENT_13 . IDENT_14 , byte [ ] , byte [ ] , org . apache . kafka . common . IDENT_15 ) { java . lang . Integer METHOD_9 = record . METHOD_9 ( ) ; return METHOD_9 != null ? METHOD_9 : IDENT_16 . METHOD_9 ( record . METHOD_10 ( ) , record . key ( ) , IDENT_17 , record . value ( ) , IDENT_18 , cluster ) ; }
org . junit . Assert . assertEquals ( expected , actual )