METHOD_0 ( ) { com . github . IDENT_0 . IDENT_1 . client . service . IDENT_2 client = new com . github . IDENT_0 . IDENT_1 . client . service . rest . METHOD_1 ( STRING_0 , INT_0 ) ; com . github . IDENT_0 . IDENT_1 . client . service . rest . Map < com . github . IDENT_0 . IDENT_1 . commons . config . IDENT_3 . IDENT_4 . IDENT_5 , java . lang . Long > session = client . METHOD_2 ( STRING_1 , java . lang . String . class , STRING_2 , com . github . IDENT_0 . IDENT_1 . client . service . rest . Long . class , org . apache . kafka . common . serialization . IDENT_6 . String ( ) , org . apache . kafka . common . serialization . IDENT_6 . Long ( ) ) ; "<AssertPlaceHolder>" ; } METHOD_2 ( java . lang . String , java . lang . Class , IDENT_7 , java . lang . Class , org . apache . kafka . common . serialization . IDENT_8 , org . apache . kafka . common . serialization . IDENT_8 ) { return execute ( ( ) -> METHOD_3 ( ) . METHOD_4 ( java . lang . String . format ( STRING_3 , store , com . github . IDENT_0 . IDENT_1 . client . service . rest . IDENT_9 . METHOD_5 ( ) . METHOD_6 ( IDENT_10 . serializer ( ) . serialize ( "" , key ) ) ) ) . METHOD_7 ( STRING_4 , IDENT_10 . getClass ( ) . getName ( ) ) . METHOD_7 ( STRING_5 , IDENT_11 . getClass ( ) . getName ( ) ) . build ( ) , ( bytes ) -> { com . github . IDENT_0 . IDENT_1 . client . service . rest . IDENT_12 IDENT_13 = mapper . METHOD_8 ( bytes , . class ) ; return new IDENT_14 < com . github . IDENT_0 . IDENT_1 . client . service . rest . IDENT_5 , com . github . IDENT_0 . IDENT_1 . client . service . rest . IDENT_15 > ( IDENT_13 . METHOD_9 ( ) . stream ( ) . map ( ( IDENT_16 ) -> { return new IDENT_17 < com . github . IDENT_0 . IDENT_1 . client . service . rest . IDENT_5 , com . github . IDENT_0 . IDENT_1 . client . service . rest . IDENT_15 > ( IDENT_16 , METHOD_10 ( IDENT_18 , IDENT_11 , IDENT_16 . getValue ( ) ) ) ; } ) . collect ( java . util . stream . IDENT_19 . METHOD_11 ( com . github . IDENT_0 . IDENT_1 . client . service . rest . IDENT_17 :: getKey , ( IDENT_20 ) -> IDENT_20 . getValue ( ) ) ) ) ; } , ( ) -> com . github . IDENT_0 . IDENT_1 . client . service . rest . Collections . METHOD_12 ( ) ) ; }
org . junit . Assert . assertThat ( session . size ( ) , is ( equalTo ( 2 ) ) )