METHOD_0 ( ) { java . util . List < org . apache . kafka . IDENT_0 . consumer . IDENT_1 < java . lang . String , java . lang . String > > IDENT_2 = new java . util . METHOD_1 ( ) ; for ( Map . Entry < org . apache . kafka . common . IDENT_3 , java . lang . Long > entry : IDENT_4 . entrySet ( ) ) { IDENT_2 . add ( new org . apache . kafka . IDENT_0 . consumer . IDENT_1 < java . lang . String , java . lang . String > ( entry . getKey ( ) . METHOD_2 ( ) , entry . getKey ( ) . METHOD_3 ( ) , ( ( entry . getValue ( ) ) + 1 ) , STRING_0 , null ) ) ; } when ( records . isEmpty ( ) ) . thenReturn ( false ) ; when ( records . iterator ( ) ) . thenReturn ( IDENT_2 . iterator ( ) ) ; when ( IDENT_5 . METHOD_4 ( org . mockito . Matchers . METHOD_5 ( ) ) ) . thenReturn ( records ) . thenReturn ( records ) . thenReturn ( null ) ; java . lang . IDENT_6 < org . apache . kafka . IDENT_0 . consumer . IDENT_1 < java . lang . String , java . lang . String > > data = new org . apache . IDENT_7 . kafka . record . METHOD_6 ( IDENT_5 , IDENT_8 , new java . util . Properties ( ) ) ; int count = 0 ; for ( org . apache . kafka . IDENT_0 . consumer . IDENT_1 < java . lang . String , java . lang . String > record : data ) { count ++ ; } "<AssertPlaceHolder>" ; } iterator ( ) { if ( ( IDENT_9 ) == null ) { this . result = pipeline . run ( ) ; if ( ( result . METHOD_7 ( ) ) || ( ! ( pipeline . METHOD_8 ( ) . METHOD_9 ( STRING_1 , false ) ) ) ) { METHOD_10 ( ) ; } else { org . apache . IDENT_7 . METHOD_10 . IDENT_10 . LOG . error ( STRING_2 ) ; return com . google . common . collect . IDENT_11 . METHOD_11 ( ) ; } } return IDENT_9 . iterator ( ) ; }
org . junit . Assert . assertThat ( count , org . hamcrest . core . Is . is ( 0 ) )