METHOD_0 ( ) { java . util . List < io . IDENT_0 . examples . streams . avro . IDENT_1 > IDENT_2 = java . util . Arrays . asList ( io . IDENT_0 . examples . streams . avro . IDENT_1 . METHOD_1 ( ) . METHOD_2 ( STRING_0 ) . METHOD_3 ( true ) . METHOD_4 ( STRING_1 ) . build ( ) ) ; org . apache . kafka . streams . IDENT_3 . IDENT_4 builder = new org . apache . kafka . streams . IDENT_3 . METHOD_5 ( ) ; java . util . Properties IDENT_5 = new java . util . Properties ( ) ; IDENT_5 . put ( IDENT_6 . IDENT_7 , STRING_2 ) ; IDENT_5 . put ( IDENT_6 . IDENT_8 , io . IDENT_0 . examples . streams . IDENT_9 . IDENT_10 . METHOD_6 ( ) ) ; IDENT_5 . put ( IDENT_6 . IDENT_11 , io . IDENT_0 . examples . streams . IDENT_9 . IDENT_10 . METHOD_7 ( ) ) ; IDENT_5 . put ( IDENT_6 . IDENT_12 , org . apache . kafka . common . serialization . IDENT_13 . METHOD_8 ( ) . getClass ( ) . getName ( ) ) ; IDENT_5 . put ( IDENT_6 . IDENT_14 , io . IDENT_0 . examples . streams . utils . IDENT_15 . class ) ; IDENT_5 . put ( IDENT_16 . IDENT_17 , io . IDENT_0 . examples . streams . IDENT_9 . IDENT_10 . METHOD_9 ( ) ) ; IDENT_5 . put ( IDENT_18 . IDENT_19 , STRING_3 ) ; final org . apache . kafka . common . serialization . IDENT_20 < java . lang . String > IDENT_21 = org . apache . kafka . common . serialization . IDENT_13 . String ( ) ; final org . apache . kafka . common . serialization . IDENT_20 < io . IDENT_0 . examples . streams . avro . IDENT_1 > IDENT_22 = new io . IDENT_0 . examples . streams . utils . METHOD_10 ( ) ; boolean IDENT_23 = false ; IDENT_22 . METHOD_11 ( java . util . Collections . METHOD_12 ( IDENT_16 . IDENT_17 , io . IDENT_0 . examples . streams . IDENT_9 . IDENT_10 . METHOD_9 ( ) ) , IDENT_23 ) ; org . apache . kafka . streams . IDENT_3 . IDENT_24 < java . lang . String , io . IDENT_0 . examples . streams . avro . IDENT_1 > stream = builder . stream ( io . IDENT_0 . examples . streams . IDENT_9 . IDENT_25 ) ; stream . to ( IDENT_21 , IDENT_22 , io . IDENT_0 . examples . streams . IDENT_9 . IDENT_26 ) ; org . apache . kafka . streams . IDENT_27 streams = new org . apache . kafka . streams . METHOD_13 ( builder , IDENT_5 ) ; streams . start ( ) ; java . util . Properties IDENT_28 = new java . util . Properties ( ) ; IDENT_28 . put ( IDENT_29 . IDENT_8 , io . IDENT_0 . examples . streams . IDENT_9 . IDENT_10 . METHOD_6 ( ) ) ; IDENT_28 . put ( IDENT_29 . IDENT_30 , STRING_4 ) ; IDENT_28 . put ( IDENT_29 . IDENT_31 , 0 ) ; IDENT_28 . put ( IDENT_29 . IDENT_32 , org . apache . kafka . common . serialization . IDENT_33 . class ) ; IDENT_28 . put ( IDENT_29 . IDENT_34 , io . IDENT_0 . kafka . IDENT_35 . IDENT_36 . class ) ; IDENT_28 . put ( IDENT_16 . IDENT_17 , io . IDENT_0 . examples . streams . IDENT_9 . IDENT_10 . METHOD_9 ( ) ) ; io . IDENT_0 . examples . streams . IDENT_37 . METHOD_14 ( io . IDENT_0 . examples . streams . IDENT_9 . IDENT_25 , IDENT_2 , IDENT_28 ) ; java . util . Properties IDENT_38 = new java . util . Properties ( ) ; IDENT_38 . put ( IDENT_18 . IDENT_8 , io . IDENT_0 . examples . streams . IDENT_9 . IDENT_10 . METHOD_6 ( ) ) ; IDENT_38 . put ( IDENT_18 . IDENT_39 , STRING_5 ) ; IDENT_38 . put ( IDENT_18 . IDENT_19 , STRING_3 ) ; IDENT_38 . put ( IDENT_18 . IDENT_40 , org . apache . kafka . common . serialization . IDENT_41 . class ) ; IDENT_38 . put ( IDENT_18 . IDENT_42 , io . IDENT_0 . kafka . IDENT_35 . IDENT_43 . class ) ; IDENT_38 . put ( IDENT_16 . IDENT_17 , io . IDENT_0 . examples . streams . IDENT_9 . IDENT_10 . METHOD_9 ( ) ) ; IDENT_38 . put ( IDENT_44 . IDENT_45 , true ) ; java . util . List < io . IDENT_0 . examples . streams . avro . IDENT_1 > IDENT_46 = io . IDENT_0 . examples . streams . IDENT_37 . METHOD_15 ( IDENT_38 , io . IDENT_0 . examples . streams . IDENT_9 . IDENT_26 , IDENT_2 . size ( ) ) ; streams . close ( ) ; "<AssertPlaceHolder>" ; } close ( ) { IDENT_47 . close ( ) ; }
org . junit . Assert . assertEquals ( IDENT_2 , IDENT_46 )