METHOD_0 ( ) { for ( java . lang . String IDENT_0 : com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 . IDENT_5 ) { final java . lang . String IDENT_6 = STRING_0 + IDENT_0 ; METHOD_1 ( IDENT_6 ) ; kafka . IDENT_7 . consumer . IDENT_8 consumer = METHOD_2 ( ) ; java . util . Map < java . lang . String , java . lang . Integer > IDENT_9 = new java . util . HashMap < java . lang . String , java . lang . Integer > ( ) ; IDENT_9 . put ( IDENT_6 , 1 ) ; final java . util . Map < java . lang . String , java . util . List < kafka . consumer . IDENT_10 < byte [ ] , byte [ ] > > > streams = consumer . METHOD_3 ( IDENT_9 ) ; error = null ; java . lang . Thread t = new java . lang . Thread ( new java . lang . METHOD_4 ( ) { @ com . IDENT_1 . IDENT_2 . IDENT_3 . Override public void run ( ) { try { kafka . consumer . IDENT_11 < byte [ ] , byte [ ] > it = streams . get ( IDENT_6 ) . get ( 0 ) . iterator ( ) ; for ( int i = 0 ; i < ( com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 . IDENT_12 . size ( ) ) ; i ++ ) { java . lang . String line = new java . lang . String ( it . next ( ) . message ( ) ) ; java . lang . String message = line . split ( " " , 4 ) [ 3 ] . trim ( ) ; "<AssertPlaceHolder>" ; } } catch ( java . lang . Throwable t ) { METHOD_5 ( t ) ; } } } ) ; t . start ( ) ; java . lang . Thread . sleep ( 100 ) ; com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_13 . IDENT_14 IDENT_13 = METHOD_6 ( IDENT_6 , IDENT_0 ) ; for ( java . lang . String log : com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 . IDENT_12 ) { byte [ ] msg = ( ( ( java . lang . System . currentTimeMillis ( ) ) + STRING_1 ) + log ) . getBytes ( ) ; IDENT_13 . METHOD_7 ( msg , 0 , msg . length ) ; } t . join ( ) ; if ( ( error ) != null ) { throw error ; } } } run ( ) { com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . info ( STRING_2 3 ) ; while ( true ) { javax . security . auth . IDENT_17 . IDENT_18 IDENT_19 = METHOD_8 ( ) ; long now = com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_20 . METHOD_9 ( ) ; long IDENT_21 ; java . util . Date IDENT_22 ; if ( IDENT_19 == null ) { IDENT_21 = now + ( com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . IDENT_23 ) ; IDENT_22 = new java . util . Date ( IDENT_21 ) ; com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . warn ( STRING_3 1 , IDENT_22 ) ; } else { IDENT_21 = METHOD_10 ( IDENT_19 ) ; long IDENT_24 = IDENT_19 . METHOD_11 ( ) . getTime ( ) ; java . util . Date IDENT_25 = new java . util . Date ( IDENT_24 ) ; if ( ( IDENT_26 ) && ( IDENT_19 . METHOD_11 ( ) . equals ( IDENT_19 . METHOD_12 ( ) ) ) ) { java . lang . Object [ ] IDENT_27 = new java . lang . Object [ ] { IDENT_25 , METHOD_13 ( ) , METHOD_13 ( ) } ; com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . error ( ( STRING_2 5 + ( ( ( ( ( STRING_4 + STRING_5 ) + STRING_6 ) + STRING_3 4 ) + STRING_2 2 ) + STRING_2 4 ) ) , IDENT_27 ) ; return ; } if ( ( IDENT_21 > IDENT_24 ) || ( ( now + ( com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . IDENT_23 ) ) > IDENT_24 ) ) { IDENT_21 = now ; } else { if ( IDENT_21 < ( now + ( com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . IDENT_23 ) ) ) { java . util . Date IDENT_28 = new java . util . Date ( IDENT_21 ) ; java . util . Date IDENT_29 = new java . util . Date ( ( now + ( com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . IDENT_23 ) ) ) ; java . lang . Object [ ] IDENT_27 = new java . lang . Object [ ] { IDENT_28 , IDENT_29 , ( com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . IDENT_23 ) / 1000 } ; com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . warn ( ( STRING_3 2 + ( STRING_2 8 + STRING_7 ) ) , IDENT_27 ) ; } IDENT_21 = java . lang . Math . max ( IDENT_21 , ( now + ( com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . IDENT_23 ) ) ) ; } IDENT_22 = new java . util . Date ( IDENT_21 ) ; if ( IDENT_21 > IDENT_24 ) { java . lang . Object [ ] IDENT_27 = new java . lang . Object [ ] { IDENT_22 , IDENT_25 } ; com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . error ( ( STRING_3 5 + ( STRING_2 9 + STRING_3 0 ) ) , IDENT_27 ) ; return ; } } if ( now == IDENT_21 ) { com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . info ( STRING_2 7 ) ; } else { if ( now < IDENT_21 ) { java . util . Date IDENT_28 = new java . util . Date ( IDENT_21 ) ; com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . info ( STRING_8 , IDENT_28 . toString ( ) ) ; try { java . lang . Thread . sleep ( ( IDENT_21 - now ) ) ; } catch ( java . lang . IDENT_30 IDENT_31 ) { com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . warn ( STRING_9 ) ; break ; } } else { com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . error ( ( STRING_2 6 + ( ( STRING_3 3 + STRING_2 0 ) + STRING_2 ) ) , IDENT_22 ) ; break ; } } if ( IDENT_26 ) { com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . error ( STRING_10 ) ; break ; } try { int IDENT_32 = 1 ; while ( IDENT_32 >= 0 ) { try { METHOD_14 ( ) ; break ; } catch ( javax . security . auth . IDENT_33 . IDENT_34 IDENT_35 ) { if ( IDENT_32 > 0 ) { OP_0 IDENT_32 ; try { java . lang . Thread . sleep ( ( 10 * 1000 ) ) ; } catch ( java . lang . IDENT_30 e ) { com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . error ( STRING_11 , IDENT_35 ) ; throw IDENT_35 ; } } else { com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . error ( STRING_2 1 , METHOD_13 ( ) , IDENT_35 ) ; } } } } catch ( javax . security . auth . IDENT_33 . IDENT_34 IDENT_35 ) { com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_15 . IDENT_16 . LOG . error ( STRING_3 , IDENT_35 ) ; break ; } } }
org . junit . Assert . assertEquals ( com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 . IDENT_12 . get ( i ) , message )