METHOD_0 ( ) { short version = 100 ; org . apache . kafka . common . protocol . types . Schema IDENT_0 = new org . apache . kafka . common . protocol . types . Schema ( new org . apache . kafka . common . protocol . types . Field ( IDENT_1 . IDENT_2 , new org . apache . kafka . common . protocol . types . METHOD_1 ( org . apache . kafka . common . protocol . types . Type . IDENT_3 ) ) , new org . apache . kafka . common . protocol . types . Field ( IDENT_1 . IDENT_4 , org . apache . kafka . common . protocol . types . Type . IDENT_5 ) , new org . apache . kafka . common . protocol . types . Field ( "foo" , org . apache . kafka . common . protocol . types . Type . IDENT_3 ) ) ; org . apache . kafka . common . protocol . types . IDENT_6 IDENT_7 = new org . apache . kafka . common . protocol . types . METHOD_2 ( IDENT_0 ) ; IDENT_7 . set ( IDENT_1 . IDENT_2 , new java . lang . Object [ ] { STRING_0 } ) ; IDENT_7 . set ( IDENT_1 . IDENT_4 , java . nio . ByteBuffer . METHOD_3 ( new byte [ 0 ] ) ) ; IDENT_7 . set ( "foo" , "bar" ) ; org . apache . kafka . common . protocol . types . METHOD_2 IDENT_8 = new org . apache . kafka . common . protocol . types . METHOD_2 ( IDENT_1 . IDENT_9 ) ; IDENT_8 . set ( IDENT_1 . IDENT_10 , version ) ; java . nio . ByteBuffer buffer = java . nio . ByteBuffer . METHOD_4 ( ( ( IDENT_7 . METHOD_5 ( ) ) + ( IDENT_8 . METHOD_5 ( ) ) ) ) ; IDENT_8 . METHOD_6 ( buffer ) ; IDENT_7 . METHOD_6 ( buffer ) ; buffer . METHOD_7 ( ) ; org . apache . kafka . IDENT_11 . consumer . IDENT_12 . IDENT_13 . IDENT_14 IDENT_15 = org . apache . kafka . IDENT_11 . consumer . IDENT_12 . IDENT_1 . METHOD_8 ( buffer ) ; "<AssertPlaceHolder>" ; } METHOD_9 ( ) { return java . util . Arrays . METHOD_10 ( org . apache . kafka . streams . tests . IDENT_16 . IDENT_17 , org . apache . kafka . streams . tests . IDENT_16 . IDENT_17 . length ) ; }
org . junit . Assert . assertEquals ( java . util . Arrays . asList ( STRING_0 ) , IDENT_15 . METHOD_9 ( ) )