METHOD_0 ( ) { props . put ( IDENT_0 . IDENT_1 , com . google . IDENT_2 . kafka . IDENT_3 . IDENT_4 . IDENT_5 ) ; task . start ( props ) ; java . util . List < org . apache . kafka . connect . IDENT_3 . IDENT_6 > records = METHOD_1 ( ) ; task . put ( records ) ; org . mockito . IDENT_7 < com . google . IDENT_2 . v1 . IDENT_8 > IDENT_9 = org . mockito . IDENT_7 . METHOD_2 ( com . google . IDENT_2 . v1 . IDENT_8 . class ) ; verify ( IDENT_10 , times ( 2 ) ) . METHOD_3 ( IDENT_9 . METHOD_4 ( ) ) ; java . util . List < com . google . IDENT_2 . v1 . IDENT_8 > IDENT_11 = IDENT_9 . METHOD_5 ( ) ; "<AssertPlaceHolder>" ; } METHOD_6 ( ) { java . util . List < com . google . IDENT_2 . v1 . IDENT_8 > messages = new java . util . ArrayList ( ) ; java . util . Map < java . lang . String , java . lang . String > attributes = new java . util . HashMap ( ) ; attributes . put ( IDENT_12 . IDENT_13 , com . google . IDENT_2 . kafka . IDENT_3 . IDENT_4 . IDENT_14 ) ; messages . add ( com . google . IDENT_2 . v1 . IDENT_8 . METHOD_7 ( ) . METHOD_8 ( attributes ) . METHOD_9 ( com . google . IDENT_2 . kafka . IDENT_3 . IDENT_4 . IDENT_15 ) . build ( ) ) ; messages . add ( com . google . IDENT_2 . v1 . IDENT_8 . METHOD_7 ( ) . METHOD_8 ( attributes ) . METHOD_9 ( com . google . IDENT_2 . kafka . IDENT_3 . IDENT_4 . IDENT_16 ) . build ( ) ) ; return messages ; }
org . junit . Assert . assertEquals ( IDENT_11 , METHOD_6 ( ) )