METHOD_0 ( ) { org . apache . kafka . connect . data . IDENT_0 builder = org . apache . kafka . connect . data . IDENT_0 . METHOD_1 ( ) . field ( STRING_0 6 , org . apache . kafka . connect . data . IDENT_0 . METHOD_2 ( ) . METHOD_3 ( ( ( byte ) ( 2 ) ) ) . doc ( STRING_0 ) . build ( ) ) . field ( STRING_1 , Schema . IDENT_1 ) . field ( STRING_0 2 , Schema . IDENT_2 ) . field ( STRING_0 5 , Schema . IDENT_3 ) . field ( STRING_2 , Schema . IDENT_4 ) . field ( STRING_0 3 , Schema . IDENT_5 ) . field ( STRING_0 7 , Schema . IDENT_6 ) . field ( STRING_0 1 , Schema . IDENT_7 ) . field ( STRING_0 4 , Schema . IDENT_8 ) . field ( STRING_0 0 , org . apache . kafka . connect . data . IDENT_0 . array ( Schema . IDENT_7 ) . build ( ) ) . field ( STRING_3 , org . apache . kafka . connect . data . IDENT_0 . map ( Schema . IDENT_7 , Schema . IDENT_2 ) . build ( ) ) . field ( STRING_4 , org . apache . kafka . connect . data . IDENT_0 . map ( Schema . IDENT_2 , Schema . IDENT_2 ) . build ( ) ) ; org . apache . kafka . connect . data . Schema schema = builder . build ( ) ; org . apache . kafka . connect . data . IDENT_9 original = new org . apache . kafka . connect . data . METHOD_4 ( schema ) . put ( STRING_0 6 , ( ( byte ) ( 12 ) ) ) . put ( STRING_1 , ( ( short ) ( 12 ) ) ) . put ( STRING_0 2 , 12 ) . put ( STRING_0 5 , INT_0 ) . put ( STRING_2 , FLOAT_0 ) . put ( STRING_0 3 , FLOAT_1 ) . put ( STRING_0 7 , true ) . put ( STRING_0 1 , "foo" ) . put ( STRING_0 4 , java . nio . ByteBuffer . METHOD_5 ( "foo" . getBytes ( ) ) ) . put ( STRING_0 0 , java . util . Arrays . asList ( "a" , "b" , STRING_5 ) ) . put ( STRING_3 , java . util . Collections . METHOD_6 ( STRING_6 , 1 ) ) . put ( STRING_4 , java . util . Collections . METHOD_6 ( 1 , 1 ) ) ; org . apache . kafka . connect . data . Schema IDENT_10 = builder . version ( 1 ) . build ( ) ; org . apache . kafka . connect . data . METHOD_4 expected = new org . apache . kafka . connect . data . METHOD_4 ( IDENT_10 ) . put ( STRING_0 6 , ( ( byte ) ( 12 ) ) ) . put ( STRING_1 , ( ( short ) ( 12 ) ) ) . put ( STRING_0 2 , 12 ) . put ( STRING_0 5 , INT_0 ) . put ( STRING_2 , FLOAT_0 ) . put ( STRING_0 3 , FLOAT_1 ) . put ( STRING_0 7 , true ) . put ( STRING_0 1 , "foo" ) . put ( STRING_0 4 , java . nio . ByteBuffer . METHOD_5 ( "foo" . getBytes ( ) ) ) . put ( STRING_0 0 , java . util . Arrays . asList ( "a" , "b" , STRING_5 ) ) . put ( STRING_3 , java . util . Collections . METHOD_6 ( STRING_6 , 1 ) ) . put ( STRING_4 , java . util . Collections . METHOD_6 ( 1 , 1 ) ) ; byte [ ] IDENT_11 = converter . METHOD_7 ( io . IDENT_12 . connect . avro . IDENT_13 . IDENT_14 , original . schema ( ) , original ) ; org . apache . kafka . connect . data . IDENT_15 IDENT_16 = converter . METHOD_8 ( io . IDENT_12 . connect . avro . IDENT_13 . IDENT_14 , IDENT_11 ) ; "<AssertPlaceHolder>" ; } METHOD_8 ( java . lang . String , byte [ ] ) { try { io . IDENT_12 . kafka . IDENT_17 . IDENT_18 IDENT_19 = IDENT_20 . METHOD_9 ( IDENT_21 , IDENT_22 , value ) ; if ( IDENT_19 == null ) { return org . apache . kafka . connect . data . IDENT_15 . IDENT_23 ; } org . apache . avro . IDENT_24 . IDENT_25 IDENT_26 = IDENT_19 . container ( ) ; java . lang . Integer version = IDENT_19 . version ( ) ; if ( IDENT_26 instanceof org . apache . avro . IDENT_24 . IDENT_27 ) { return IDENT_28 . METHOD_8 ( IDENT_26 . METHOD_10 ( ) , IDENT_26 , version ) ; } else if ( IDENT_26 instanceof io . IDENT_12 . kafka . IDENT_17 . IDENT_29 ) { return IDENT_28 . METHOD_8 ( IDENT_26 . METHOD_10 ( ) , ( ( io . IDENT_12 . kafka . IDENT_17 . IDENT_29 ) ( IDENT_26 ) ) . getValue ( ) , version ) ; } throw new org . apache . kafka . connect . errors . METHOD_11 ( java . lang . String . format ( STRING_7 , IDENT_21 ) ) ; } catch ( org . apache . kafka . common . errors . IDENT_30 e ) { throw new org . apache . kafka . connect . errors . METHOD_11 ( java . lang . String . format ( STRING_8 , IDENT_21 ) , e ) ; } }
org . junit . Assert . assertEquals ( expected , IDENT_16 . value ( ) )