METHOD_0 ( ) { org . talend . components . kafka . runtime . IDENT_0 runtime = new org . talend . components . kafka . runtime . METHOD_1 ( ) ; runtime . METHOD_2 ( null , org . talend . components . kafka . runtime . IDENT_1 . METHOD_3 ( org . talend . components . kafka . runtime . IDENT_1 . METHOD_4 ( ) , org . talend . components . kafka . runtime . IDENT_1 . IDENT_2 , IDENT_3 . IDENT_4 . IDENT_5 , STRING_0 ) ) ; final java . util . List < java . lang . String > actual = new java . util . ArrayList ( ) ; runtime . METHOD_5 ( 10 , new org . talend . IDENT_6 . IDENT_7 . IDENT_8 < org . apache . avro . IDENT_9 . IDENT_10 > ( ) { @ org . talend . components . kafka . runtime . Override public void accept ( org . apache . avro . IDENT_9 . IDENT_10 IDENT_11 ) { actual . add ( IDENT_11 . toString ( ) ) ; } } ) ; "<AssertPlaceHolder>" ; } size ( ) { if ( ( IDENT_12 . getValue ( ) ) == null ) { return 0 ; } return IDENT_12 . getValue ( ) . size ( ) ; }
org . junit . Assert . assertEquals ( 10 , actual . size ( ) )