METHOD_0 ( ) { java . lang . String IDENT_0 = STRING_0 + ( new java . util . METHOD_1 ( ) . METHOD_2 ( ) ) ; IDENT_1 = org . talend . components . kafka . runtime . Person . METHOD_3 ( IDENT_0 , IDENT_2 ) ; java . util . Properties props = new java . util . Properties ( ) ; props . put ( STRING_1 , org . talend . components . kafka . runtime . IDENT_3 . IDENT_4 ) ; props . put ( STRING_2 , STRING_3 ) ; props . put ( STRING_3 1 , STRING_4 ) ; org . apache . kafka . IDENT_5 . IDENT_6 . IDENT_7 < java . lang . IDENT_8 , byte [ ] > IDENT_6 = new org . apache . kafka . IDENT_5 . IDENT_6 . METHOD_4 ( props ) ; for ( org . talend . components . kafka . runtime . Person person : IDENT_1 ) { org . apache . kafka . IDENT_5 . IDENT_6 . IDENT_9 < java . lang . IDENT_8 , byte [ ] > message = new org . apache . kafka . IDENT_5 . IDENT_6 . METHOD_5 ( org . talend . components . kafka . runtime . IDENT_3 . IDENT_10 , person . METHOD_6 ( ) ) ; IDENT_6 . METHOD_7 ( message ) ; } IDENT_6 . close ( ) ; org . talend . components . kafka . input . IDENT_11 IDENT_12 = new org . talend . components . kafka . input . METHOD_8 ( STRING_5 ) ; IDENT_12 . init ( ) ; IDENT_12 . METHOD_9 ( IDENT_13 ) ; IDENT_12 . IDENT_14 . setValue ( METHOD_8 . IDENT_15 . IDENT_16 ) ; IDENT_12 . IDENT_17 . setValue ( false ) ; IDENT_12 . IDENT_18 . setValue ( true ) ; IDENT_12 . IDENT_19 . setValue ( INT_0 ) ; org . talend . components . kafka . output . IDENT_20 IDENT_21 = new org . talend . components . kafka . output . METHOD_10 ( STRING_6 ) ; IDENT_21 . init ( ) ; IDENT_21 . METHOD_9 ( IDENT_22 ) ; IDENT_21 . IDENT_23 . setValue ( METHOD_10 . IDENT_24 . IDENT_25 ) ; IDENT_21 . IDENT_26 . setValue ( false ) ; org . talend . components . kafka . runtime . IDENT_27 IDENT_28 = new org . talend . components . kafka . runtime . METHOD_11 ( ) ; IDENT_28 . METHOD_12 ( null , IDENT_12 ) ; org . talend . components . kafka . runtime . IDENT_29 IDENT_30 = new org . talend . components . kafka . runtime . METHOD_13 ( ) ; IDENT_30 . METHOD_12 ( null , IDENT_21 ) ; pipeline . apply ( IDENT_28 ) . apply ( org . apache . beam . sdk . IDENT_31 . IDENT_32 . METHOD_14 ( new org . talend . components . kafka . runtime . IDENT_33 . METHOD_15 ( IDENT_0 ) ) ) . apply ( IDENT_30 ) ; org . apache . beam . sdk . IDENT_34 result = pipeline . run ( ) ; props = new java . util . Properties ( ) ; props . put ( STRING_1 , org . talend . components . kafka . runtime . IDENT_3 . IDENT_4 ) ; props . put ( STRING_3 2 , IDENT_0 ) ; props . put ( STRING_3 3 , STRING_7 ) ; props . put ( STRING_3 4 , STRING_3 0 ) ; props . put ( STRING_8 , STRING_9 ) ; org . apache . kafka . IDENT_5 . consumer . IDENT_35 < java . lang . String , byte [ ] > consumer = new org . apache . kafka . IDENT_5 . consumer . METHOD_16 ( props ) ; consumer . METHOD_17 ( java . util . Arrays . asList ( org . talend . components . kafka . runtime . IDENT_3 . IDENT_36 ) ) ; java . util . List < org . talend . components . kafka . runtime . Person > results = new java . util . ArrayList ( ) ; while ( true ) { org . apache . kafka . IDENT_5 . consumer . IDENT_37 < java . lang . String , byte [ ] > records = consumer . METHOD_18 ( 100 ) ; for ( org . apache . kafka . IDENT_5 . consumer . IDENT_38 < java . lang . String , byte [ ] > record : records ) { org . talend . components . kafka . runtime . Person person = org . talend . components . kafka . runtime . Person . METHOD_19 ( record . value ( ) ) ; if ( IDENT_0 . equals ( person . group ) ) { results . add ( person ) ; } } if ( ( results . size ( ) ) >= ( IDENT_2 ) ) { break ; } } "<AssertPlaceHolder>" ; } size ( ) { if ( ( IDENT_39 . getValue ( ) ) == null ) { return 0 ; } return IDENT_39 . getValue ( ) . size ( ) ; }
org . junit . Assert . assertEquals ( IDENT_1 , results )