METHOD_0 ( ) { props . put ( IDENT_0 . IDENT_1 , STRING_0 ) ; props . put ( IDENT_0 . IDENT_2 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_6 ) ; task . start ( props ) ; java . util . List < org . apache . kafka . connect . IDENT_4 . IDENT_7 > records = new java . util . ArrayList < org . apache . kafka . connect . IDENT_4 . IDENT_7 > ( ) ; records . add ( new org . apache . kafka . connect . IDENT_4 . METHOD_1 ( com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_8 , 4 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_9 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_10 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_11 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_12 , 1000 , INT_0 , org . apache . kafka . common . record . IDENT_13 . IDENT_14 ) ) ; records . add ( new org . apache . kafka . connect . IDENT_4 . METHOD_1 ( com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_8 , 4 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_9 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_10 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_11 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_15 , INT_1 , INT_2 , org . apache . kafka . common . record . IDENT_13 . IDENT_14 ) ) ; task . put ( records ) ; org . mockito . IDENT_16 < com . google . IDENT_3 . v1 . IDENT_17 > IDENT_18 = org . mockito . IDENT_16 . METHOD_2 ( com . google . IDENT_3 . v1 . IDENT_17 . class ) ; verify ( IDENT_19 , times ( 2 ) ) . METHOD_3 ( IDENT_18 . METHOD_4 ( ) ) ; java . util . List < com . google . IDENT_3 . v1 . IDENT_17 > IDENT_20 = IDENT_18 . METHOD_5 ( ) ; java . util . List < com . google . IDENT_3 . v1 . IDENT_17 > IDENT_21 = new java . util . ArrayList ( ) ; java . util . Map < java . lang . String , java . lang . String > IDENT_22 = new java . util . HashMap ( ) ; IDENT_22 . put ( IDENT_23 . IDENT_24 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_10 ) ; IDENT_22 . put ( IDENT_23 . IDENT_25 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_8 ) ; IDENT_22 . put ( IDENT_23 . IDENT_26 , STRING_1 ) ; IDENT_22 . put ( IDENT_23 . IDENT_27 , STRING_2 ) ; IDENT_22 . put ( IDENT_23 . IDENT_28 , STRING_3 ) ; IDENT_21 . add ( com . google . IDENT_3 . v1 . IDENT_17 . METHOD_6 ( ) . METHOD_7 ( IDENT_22 ) . METHOD_8 ( com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_12 ) . build ( ) ) ; java . util . Map < java . lang . String , java . lang . String > IDENT_29 = new java . util . HashMap ( ) ; IDENT_29 . put ( IDENT_23 . IDENT_24 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_10 ) ; IDENT_29 . put ( IDENT_23 . IDENT_25 , com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_8 ) ; IDENT_29 . put ( IDENT_23 . IDENT_26 , STRING_1 ) ; IDENT_29 . put ( IDENT_23 . IDENT_27 , STRING_4 ) ; IDENT_29 . put ( IDENT_23 . IDENT_28 , STRING_5 ) ; IDENT_21 . add ( com . google . IDENT_3 . v1 . IDENT_17 . METHOD_6 ( ) . METHOD_7 ( IDENT_29 ) . METHOD_8 ( com . google . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_15 ) . build ( ) ) ; "<AssertPlaceHolder>" ; } add ( T ) { delegate ( ) . add ( IDENT_30 ) ; }
org . junit . Assert . assertEquals ( IDENT_20 , IDENT_21 )