METHOD_0 ( ) { java . lang . String IDENT_0 = STRING_0 ; java . lang . String group = STRING_1 ; com . IDENT_1 . IDENT_2 . IDENT_3 . api . IDENT_4 IDENT_3 = com . IDENT_1 . IDENT_2 . IDENT_3 . api . IDENT_4 . getInstance ( ) ; com . IDENT_1 . IDENT_2 . consumer . engine . IDENT_5 engine = com . IDENT_1 . IDENT_2 . consumer . engine . IDENT_5 . getInstance ( ) ; final java . util . List < com . IDENT_1 . IDENT_2 . kafka . avro . IDENT_6 > IDENT_7 = new java . util . ArrayList ( ) ; final java . util . List < com . IDENT_1 . IDENT_2 . kafka . avro . IDENT_6 > IDENT_8 = new java . util . ArrayList ( ) ; com . IDENT_1 . IDENT_2 . consumer . engine . IDENT_9 s = new com . IDENT_1 . IDENT_2 . consumer . engine . METHOD_1 ( IDENT_0 , group , new com . IDENT_1 . IDENT_2 . consumer . IDENT_10 < com . IDENT_1 . IDENT_2 . kafka . avro . IDENT_6 > ( ) { @ com . IDENT_1 . IDENT_2 . kafka . avro . Override public void METHOD_2 ( java . util . List < com . IDENT_1 . IDENT_2 . core . message . IDENT_11 < com . IDENT_1 . IDENT_2 . kafka . avro . IDENT_6 > > IDENT_12 ) { for ( com . IDENT_1 . IDENT_2 . core . message . IDENT_11 < com . IDENT_1 . IDENT_2 . kafka . avro . IDENT_6 > msg : IDENT_12 ) { com . IDENT_1 . IDENT_2 . kafka . avro . IDENT_6 event = msg . METHOD_3 ( ) ; System . out . println ( ( STRING_2 + event ) ) ; IDENT_7 . add ( event ) ; } } } ) ; System . out . println ( STRING_3 ) ; engine . start ( java . util . Arrays . asList ( s ) ) ; int IDENT_13 = ( new java . util . METHOD_4 ( ) . METHOD_5 ( 20 ) ) + 1 ; int i = 0 ; while ( ( i ++ ) < IDENT_13 ) { com . IDENT_1 . IDENT_2 . kafka . avro . IDENT_6 event = com . IDENT_1 . IDENT_2 . kafka . avro . IDENT_14 . METHOD_6 ( ) ; com . IDENT_1 . IDENT_2 . IDENT_3 . api . IDENT_4 . IDENT_15 IDENT_16 = IDENT_3 . message ( IDENT_0 , event ) ; java . util . concurrent . IDENT_17 < com . IDENT_1 . IDENT_2 . core . result . IDENT_18 > future = IDENT_16 . METHOD_7 ( ) ; future . get ( ) ; if ( future . METHOD_8 ( ) ) { System . out . println ( ( STRING_4 + event ) ) ; IDENT_8 . add ( event ) ; } } "<AssertPlaceHolder>" ; } size ( ) { return IDENT_19 . size ( ) ; }
org . junit . Assert . assertEquals ( IDENT_8 . size ( ) , IDENT_7 . size ( ) )