METHOD_0 ( ) { java . lang . String IDENT_0 = STRING_0 ; ch . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 IDENT_5 = io . cdap . cdap . logging . pipeline . IDENT_6 . METHOD_1 ( STRING_1 , com . google . common . collect . ImmutableMap . of ( STRING_2 , STRING_3 ) , io . cdap . cdap . logging . pipeline . IDENT_7 . class . getName ( ) ) ; final io . cdap . cdap . logging . pipeline . IDENT_7 IDENT_8 = io . cdap . cdap . logging . pipeline . IDENT_6 . METHOD_2 ( IDENT_5 . METHOD_3 ( IDENT_9 . IDENT_10 ) , STRING_4 , io . cdap . cdap . logging . pipeline . IDENT_7 . class ) ; io . cdap . cdap . logging . pipeline . kafka . IDENT_11 . IDENT_12 IDENT_13 = new io . cdap . cdap . logging . pipeline . kafka . IDENT_11 . METHOD_4 ( ) ; io . cdap . cdap . logging . pipeline . kafka . IDENT_14 config = new io . cdap . cdap . logging . pipeline . kafka . METHOD_5 ( IDENT_0 , java . util . Collections . METHOD_6 ( 0 ) , INT_0 , 100 , INT_1 , INT_2 ) ; io . cdap . cdap . logging . pipeline . kafka . IDENT_11 . IDENT_15 . METHOD_7 ( IDENT_0 , 1 ) ; IDENT_5 . start ( ) ; io . cdap . cdap . logging . pipeline . kafka . IDENT_16 pipeline = new io . cdap . cdap . logging . pipeline . kafka . METHOD_8 ( new io . cdap . cdap . logging . pipeline . METHOD_9 ( io . cdap . cdap . common . conf . IDENT_17 . create ( ) , "test" , IDENT_5 , io . cdap . cdap . logging . pipeline . kafka . IDENT_11 . IDENT_18 , 0 ) , IDENT_13 , io . cdap . cdap . logging . pipeline . kafka . IDENT_11 . IDENT_15 . METHOD_10 ( ) , config ) ; pipeline . METHOD_11 ( ) ; io . cdap . cdap . common . utils . IDENT_19 . METHOD_12 ( 5 , IDENT_8 :: IDENT_20 , 3 , TimeUnit . IDENT_21 , 100 , TimeUnit . IDENT_22 ) ; long now = java . lang . System . currentTimeMillis ( ) ; METHOD_13 ( IDENT_0 , com . google . common . collect . ImmutableList . of ( io . cdap . cdap . logging . pipeline . IDENT_6 . METHOD_14 ( STRING_2 , IDENT_23 . IDENT_24 , STRING_5 , ( now - INT_3 ) ) , io . cdap . cdap . logging . pipeline . IDENT_6 . METHOD_14 ( STRING_2 , IDENT_23 . IDENT_24 , "1" , ( now - INT_4 ) ) , io . cdap . cdap . logging . pipeline . IDENT_6 . METHOD_14 ( STRING_2 , IDENT_23 . IDENT_24 , "2" , ( now + 100 ) ) ) ) ; io . cdap . cdap . common . utils . IDENT_19 . METHOD_12 ( 3 , ( ) -> IDENT_8 . METHOD_15 ( ) . size ( ) , 3 , TimeUnit . IDENT_21 , 200 , TimeUnit . IDENT_22 ) ; pipeline . METHOD_16 ( ) ; "<AssertPlaceHolder>" ; } METHOD_17 ( ) { return IDENT_25 . get ( ) ; }
org . junit . Assert . assertTrue ( ( ( IDENT_8 . METHOD_17 ( ) ) >= 20 ) )