If I didn’t understand wrong, we’re going to use both broker version and proxy version KoP: - The proxy version is responsible for lookup/auth related requests like METADATA and SASL_XXX requests - The broker version is responsible for other requests that require broker to be the topic owner, like PRODUCE and FETCH requests Right?
Thanks, Yunze > 2021年8月30日 下午11:56,Enrico Olivelli <eolive...@gmail.com> 写道: > > Il giorno lun 30 ago 2021 alle ore 17:22 Yunze Xu > <y...@streamnative.io.invalid> ha scritto: > >> +1. Great idea. >> >> I’m not familiar with Pulsar Proxy and have a question. How can a proxy >> protocol handler >> Reuse the existing code of a protocol handler? >> > > The code that runs on proxy will be much different from the code you have > in the Broker Protocol Handler. > > Basically the Proxy protocol handles do these things: > - run the custom wire protocol (by starting custom Netty endpoints) > - use the discovery service to proxy the requests to the Broker that is the > owner of the topic > - run authentication and forwards user identity (if needed) to the Broker > - performs authorization > > The Proxy protocol handler does not access the BrokerService and cannot > access Pulsar broker internals > > Enrico > > > >> >> Thanks, >> Yunze >> >>> 2021年8月30日 下午4:47,Enrico Olivelli <eolive...@gmail.com> 写道: >>> >>> Hello Pulsar fellows, >>> >>> I have prepared a PIP about adding support for Protocol Handlers >>> >>> This is the GDoc >>> >>> >> https://docs.google.com/document/d/1Hlc_BOpQTkWX8FgrvWSfk6h5xTQKMXnTcSuil0Nznrg/edit?usp=sharing >>> >>> >>> This is the PR for the implementation >>> https://github.com/apache/pulsar/pull/11838/files >>> >>> I am pretty sure that this PIP will make life of developers of Protocol >>> Handlers and of Administrators who deploy Protocol Handlers very nicer >>> >>> We are still working on the formal PIP process, at the moment I am >> sharing >>> with you the document. >>> My understanding is that after the discussion, I will start a VOTE >> thread, >>> and if the VOTE passes we can move forward with reviewing the PR, and >>> hopefully merge this feature for Pulsar 2.9.0 >>> >>> Enrico >> >>