Hazelcastsb:SourceBuilder1. Setupsubmit jobnew()context:FunctionExnew()call:BiFunctionExstream("wikipedia", context)fillBuffer(call)destroyFn(es)2. Runapply(Processor.Context)new()w:WikipediaChangeEventHandlernew(handler, "https://stream.wikimedia.org/v2/stream/recentchange")es:EventSourcestart()return w & espar[Hazelcast Job]new()buf:SourceBufferapply(w, es, buf)loopalt[queue not empty and counter < 100]remove()return stringnew JSONObject(string)add(json)increase counter[SSE subscription]fetch dataonMessage(event, message)queue message data3. Cleanupcancel jobclose()shutdown()onClosed()