METHOD_0 ( ) { final org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . IDENT_2 info = new org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 ( 1 , IDENT_3 , IDENT_4 , IDENT_5 , 0 ) ; final org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 IDENT_6 = new org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 ( 1 , METHOD_1 . IDENT_7 , IDENT_3 , IDENT_4 , java . util . Collections . < org . apache . kafka . streams . state . IDENT_8 , java . util . Set < org . apache . kafka . common . IDENT_9 > > METHOD_2 ( ) , 0 ) ; "<AssertPlaceHolder>" ; } decode ( java . nio . ByteBuffer ) { data . METHOD_3 ( ) ; try ( final java . io . IDENT_10 in = new java . io . METHOD_4 ( new org . apache . kafka . common . utils . METHOD_5 ( data ) ) ) { final org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 IDENT_11 ; final int IDENT_12 = in . METHOD_6 ( ) ; final int IDENT_13 ; switch ( IDENT_12 ) { case 1 : IDENT_11 = new org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 ( IDENT_12 , org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 . IDENT_7 ) ; org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 . METHOD_7 ( IDENT_11 , in ) ; break ; case 2 : IDENT_11 = new org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 ( IDENT_12 , org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 . IDENT_7 ) ; org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 . METHOD_8 ( IDENT_11 , in ) ; break ; case 3 : IDENT_13 = in . METHOD_6 ( ) ; IDENT_11 = new org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 ( IDENT_12 , IDENT_13 ) ; org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 . METHOD_9 ( IDENT_11 , in ) ; break ; case 4 : IDENT_13 = in . METHOD_6 ( ) ; IDENT_11 = new org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 ( IDENT_12 , IDENT_13 ) ; org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 . METHOD_10 ( IDENT_11 , in ) ; break ; default : final org . apache . kafka . streams . errors . IDENT_14 IDENT_15 = new org . apache . kafka . streams . errors . METHOD_11 ( ( ( ( ( STRING_0 + STRING_1 ) + IDENT_12 ) + STRING_2 ) + ( org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 . IDENT_16 ) ) ) ; org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 . log . error ( IDENT_15 . getMessage ( ) , IDENT_15 ) ; throw IDENT_15 ; } return IDENT_11 ; } catch ( final java . io . IOException ex ) { throw new org . apache . kafka . streams . errors . METHOD_11 ( STRING_3 , ex ) ; } }
org . junit . Assert . assertEquals ( IDENT_6 , org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 . METHOD_1 . decode ( info . encode ( ) ) )