METHOD_0 ( ) { final java . util . List < org . apache . kafka . streams . IDENT_0 < java . lang . Integer , java . lang . String > > IDENT_1 = java . util . Arrays . asList ( new org . apache . kafka . streams . METHOD_1 ( 0 , STRING_0 ) , new org . apache . kafka . streams . METHOD_1 ( 1 , STRING_1 ) , new org . apache . kafka . streams . METHOD_1 ( 2 , STRING_2 ) , new org . apache . kafka . streams . METHOD_1 ( 3 , STRING_3 ) ) ; final java . lang . String [ ] IDENT_2 = new java . lang . String [ ] { STRING_4 , STRING_5 , STRING_6 , STRING_7 } ; for ( final org . apache . kafka . streams . METHOD_1 < java . lang . Integer , java . lang . String > record : IDENT_1 ) { IDENT_3 . process ( record . key , record . value ) ; } IDENT_3 . close ( ) ; final java . lang . String [ ] IDENT_4 = new java . lang . String ( IDENT_5 . toByteArray ( ) , java . nio . IDENT_6 . IDENT_7 . UTF_8 ) . split ( STRING_8 ) ; for ( int i = 0 ; i < ( IDENT_4 . length ) ; i ++ ) { "<AssertPlaceHolder>" ; } } split ( int ) { java . util . IDENT_8 < org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_11 . IDENT_12 > IDENT_13 = new java . util . METHOD_2 ( ) ; org . apache . kafka . common . record . IDENT_14 IDENT_15 = IDENT_16 . build ( ) ; java . util . Iterator < org . apache . kafka . common . record . IDENT_17 > IDENT_18 = IDENT_15 . METHOD_3 ( ) . iterator ( ) ; if ( ! ( IDENT_18 . hasNext ( ) ) ) throw new java . lang . IllegalStateException ( STRING_9 ) ; org . apache . kafka . common . record . IDENT_19 IDENT_20 = IDENT_18 . next ( ) ; if ( ( ( IDENT_20 . METHOD_4 ( ) ) < ( IDENT_21 ) ) && ( ! ( IDENT_20 . METHOD_5 ( ) ) ) ) throw new java . lang . IllegalArgumentException ( ( STRING_10 + STRING_11 ) ) ; if ( IDENT_18 . hasNext ( ) ) throw new java . lang . IllegalArgumentException ( STRING_12 ) ; java . util . Iterator < org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_11 . IDENT_12 . IDENT_22 > IDENT_23 = IDENT_24 . iterator ( ) ; org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_11 . IDENT_12 batch = null ; for ( org . apache . kafka . common . record . IDENT_25 record : IDENT_20 ) { assert IDENT_23 . hasNext ( ) ; org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_11 . IDENT_12 . IDENT_22 IDENT_26 = IDENT_23 . next ( ) ; if ( batch == null ) batch = METHOD_6 ( record , IDENT_27 ) ; if ( ! ( batch . METHOD_7 ( record . METHOD_8 ( ) , record . key ( ) , record . value ( ) , record . headers ( ) , IDENT_26 ) ) ) { METHOD_3 . add ( batch ) ; batch = METHOD_6 ( record , IDENT_27 ) ; batch . METHOD_7 ( record . METHOD_8 ( ) , record . key ( ) , record . value ( ) , record . headers ( ) , IDENT_26 ) ; } } if ( batch != null ) METHOD_3 . add ( batch ) ; IDENT_28 . set ( IDENT_29 . IDENT_30 , org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_11 . IDENT_31 , new org . apache . kafka . common . errors . METHOD_9 ( ) ) ; IDENT_28 . METHOD_10 ( ) ; if ( METHOD_11 ( ) ) { int IDENT_32 = METHOD_12 ( ) ; org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_11 . IDENT_33 IDENT_34 = new org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_11 . METHOD_13 ( METHOD_14 ( ) , METHOD_15 ( ) ) ; for ( org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_11 . IDENT_12 IDENT_35 : METHOD_3 ) { IDENT_35 . METHOD_16 ( IDENT_34 , IDENT_32 , METHOD_17 ( ) ) ; IDENT_32 += IDENT_35 . IDENT_36 ; } } return METHOD_3 ; }
org . junit . Assert . assertEquals ( IDENT_2 [ i ] , IDENT_4 [ i ] )