METHOD_0 ( ) { final org . apache . kafka . streams . state . IDENT_0 . IDENT_1 cache = new org . apache . kafka . streams . state . IDENT_0 . METHOD_1 ( IDENT_2 , INT_0 , new org . apache . kafka . streams . processor . IDENT_0 . METHOD_2 ( new org . apache . kafka . common . metrics . METHOD_3 ( ) ) ) ; final java . util . List < byte [ ] > IDENT_3 = new java . util . ArrayList ( ) ; cache . METHOD_4 ( IDENT_4 , ( IDENT_5 ) -> { for ( final org . apache . kafka . streams . state . IDENT_0 . METHOD_1 . IDENT_6 IDENT_7 : IDENT_5 ) { IDENT_3 . add ( IDENT_7 . key ( ) . get ( ) ) ; } } ) ; final java . util . List < byte [ ] > IDENT_8 = java . util . Arrays . asList ( new byte [ ] { 0 } , new byte [ ] { 1 } , new byte [ ] { 2 } ) ; for ( final byte [ ] bytes : IDENT_8 ) { cache . put ( IDENT_4 , org . apache . kafka . common . utils . IDENT_9 . METHOD_5 ( bytes ) , METHOD_6 ( bytes ) ) ; } cache . put ( IDENT_10 , org . apache . kafka . common . utils . IDENT_9 . METHOD_5 ( new byte [ ] { 4 } ) , METHOD_6 ( new byte [ ] { 4 } ) ) ; cache . METHOD_7 ( IDENT_4 ) ; "<AssertPlaceHolder>" ; } METHOD_7 ( java . util . Map ) { long IDENT_11 = java . lang . System . currentTimeMillis ( ) ; for ( java . util . Map < java . lang . String , java . lang . Object > data : IDENT_12 ) { data . put ( STRING_0 , IDENT_11 ) ; data . put ( STRING_1 , true ) ; java . lang . String IDENT_13 ; try { IDENT_13 = org . apache . kafka . connect . tools . IDENT_14 . IDENT_15 . METHOD_8 ( data ) ; } catch ( com . fasterxml . jackson . core . IDENT_16 e ) { IDENT_13 = STRING_2 + ( e . getMessage ( ) ) ; } System . out . println ( IDENT_13 ) ; } IDENT_12 . METHOD_9 ( ) ; }
org . junit . Assert . assertEquals ( java . util . Collections . emptyList ( ) , IDENT_3 )