METHOD_0 ( ) { java . io . File IDENT_0 = java . io . File . METHOD_1 ( STRING_0 9 , STRING_1 ) ; IDENT_0 . METHOD_2 ( ) ; java . io . IDENT_1 IDENT_2 = new java . io . METHOD_3 ( IDENT_0 ) ; IDENT_2 . write ( IDENT_3 . IDENT_4 ) ; IDENT_2 . close ( ) ; java . io . File IDENT_5 = java . io . File . METHOD_1 ( STRING_2 , STRING_0 8 ) ; IDENT_5 . METHOD_2 ( ) ; java . io . METHOD_3 IDENT_6 = new java . io . METHOD_3 ( IDENT_5 ) ; IDENT_6 . write ( java . lang . String . format ( IDENT_3 . IDENT_7 , com . IDENT_8 . IDENT_9 . test . IDENT_10 . IDENT_11 , com . IDENT_8 . IDENT_9 . test . IDENT_10 . IDENT_12 , com . IDENT_8 . IDENT_9 . test . IDENT_10 . IDENT_13 , IDENT_14 . port ( ) ) ) ; IDENT_6 . close ( ) ; java . lang . String [ ] IDENT_15 = new java . lang . String [ ] { STRING_0 6 , IDENT_0 . getAbsolutePath ( ) , STRING_3 , IDENT_5 . getAbsolutePath ( ) , STRING_4 , STRING_0 3 , STRING_0 1 , STRING_0 0 , STRING_0 5 , STRING_0 0 } ; com . IDENT_8 . IDENT_9 . IDENT_16 . METHOD_4 ( IDENT_15 ) ; java . util . Properties IDENT_17 = new java . util . Properties ( ) ; IDENT_17 . setProperty ( STRING_5 , ( ( ( com . IDENT_8 . IDENT_9 . test . IDENT_10 . IDENT_11 ) + STRING_6 ) + ( com . IDENT_8 . IDENT_9 . test . IDENT_10 . IDENT_12 ) ) ) ; IDENT_17 . setProperty ( STRING_0 4 , STRING_2 0 ) ; IDENT_17 . setProperty ( STRING_7 , STRING_8 ) ; IDENT_17 . setProperty ( STRING_9 , STRING_8 ) ; IDENT_17 . put ( STRING_0 , STRING_0 2 ) ; org . apache . kafka . IDENT_18 . consumer . IDENT_19 < java . lang . String , java . lang . String > consumer = new org . apache . kafka . IDENT_18 . consumer . METHOD_5 ( IDENT_17 ) ; consumer . METHOD_6 ( java . util . Arrays . asList ( com . IDENT_8 . IDENT_9 . test . IDENT_10 . IDENT_20 ) ) ; org . apache . kafka . IDENT_18 . consumer . IDENT_21 < java . lang . String , java . lang . String > records = consumer . METHOD_7 ( INT_0 ) ; "<AssertPlaceHolder>" ; } METHOD_4 ( java . lang . String [ ] ) { IDENT_22 . IDENT_23 parser = new IDENT_22 . METHOD_8 ( ) ; IDENT_22 . IDENT_24 < java . lang . String > IDENT_0 = parser . METHOD_9 ( STRING_10 , STRING_11 ) . METHOD_10 ( ) . METHOD_11 ( STRING_12 4 ) . METHOD_12 ( java . lang . String . class ) ; IDENT_22 . IDENT_24 < java . lang . String > IDENT_25 = parser . METHOD_9 ( STRING_13 , STRING_12 2 ) . METHOD_10 ( ) . METHOD_11 ( STRING_12 3 ) . METHOD_12 ( java . lang . String . class ) ; IDENT_22 . IDENT_24 < java . lang . Integer > IDENT_26 = parser . METHOD_9 ( STRING_14 , STRING_15 ) . METHOD_10 ( ) . METHOD_11 ( STRING_12 5 ) . METHOD_12 ( com . IDENT_8 . IDENT_9 . Integer . class ) ; IDENT_22 . IDENT_24 < java . lang . Integer > IDENT_27 = parser . METHOD_9 ( STRING_12 0 , STRING_12 6 ) . METHOD_10 ( ) . METHOD_11 ( STRING_16 ) . METHOD_12 ( com . IDENT_8 . IDENT_9 . Integer . class ) ; IDENT_22 . IDENT_24 < java . lang . Integer > IDENT_28 = parser . METHOD_9 ( STRING_17 , STRING_12 ) . METHOD_10 ( ) . METHOD_11 ( STRING_18 ) . METHOD_12 ( com . IDENT_8 . IDENT_9 . Integer . class ) ; if ( ( args . length ) == 0 ) { kafka . utils . IDENT_29 . METHOD_13 ( parser , STRING_19 ) ; } IDENT_22 . IDENT_30 options = parser . parse ( args ) ; com . IDENT_8 . IDENT_9 . IDENT_16 . METHOD_14 ( parser , options , IDENT_0 , IDENT_25 , IDENT_26 , IDENT_27 , IDENT_28 ) ; try { int IDENT_31 = options . valueOf ( IDENT_28 ) ; for ( int i = 0 ; i < IDENT_31 ; i ++ ) { com . IDENT_8 . IDENT_9 . IDENT_16 IDENT_32 = new com . IDENT_8 . IDENT_9 . METHOD_15 ( options . valueOf ( IDENT_0 ) , options . valueOf ( IDENT_25 ) , options . valueOf ( IDENT_26 ) , options . valueOf ( IDENT_27 ) ) ; IDENT_32 . start ( ) ; } } catch ( java . lang . Exception e ) { com . IDENT_8 . IDENT_9 . METHOD_15 . LOGGER . log ( IDENT_33 . IDENT_34 , STRING_12 1 , e ) ; } }
org . junit . Assert . assertTrue ( STRING_0 7 , ( ( records . count ( ) ) > 0 ) )