-
Notifications
You must be signed in to change notification settings - Fork 128
[FEATURE] Proxy support for KoP #57
Comments
Hi @jiazhai! How did you plan to develop this feature? How can I help? 😄 |
Currently this is still in our backlog. and not start working on it in our side. If anyone is interested to contribute to this PR welcome to comments on this issue. And Pierre already did some investigation on this, Thanks for @PierreZ's help on this. |
@jiazhai @PierreZ I mean, in Pulsar we have the "Pulsar proxy" that hides the complexity of the cluster inside k8s. From the documentation I see that I should setup one Envoy proxy per each Pulsar broker, this is very awkward if you have a large Pulsar cluster, especially in case that the cluster is dynamically scaling up and down. https://github.com/streamnative/kop/blob/master/docs/envoy-proxy.md "For each broker with KoP enabled, a dependent Envoy proxy is required. Assuming that you have N brokers whose internal hostname is pulsar-broker-, where i is the broker ID that varies from 0 to N-1." |
@eolivelli Yes, not like Pulsar proxy, Envoy acts more like a sidecar. Currently we have no proxy for KoP like Pulsar proxy. |
@BewareMyPower @merlimat @jiazhai @PierreZ I will be happy to share my prototype and share my work upstream to this repository. |
@eolivelli It would be great to have protocol handlers support in the Pulsar Proxy. |
This patch introduces a little refactor in order to support the implementation of a separate KOP Proxy Module: - allow to access internal ByteBuf of KafkaHeaderAndRequest, in order to allow zero-copy request magement in the Proxy - extract some static methods in order to use the same algorithm for mapping coordinators Relates to #57 Co-authored-by: Enrico Olivelli <eolivelli@apache.org>
@jiazhai @BewareMyPower @PierreZ @sijie @merlimat I have already implemented a working prototype, the performances with the proxy are the same as while using regular Pulsar proxy. I will be happy to contribute the prototype to this repository and continue the development directly here and not in my repo. |
This patch introduces a little refactor in order to support the implementation of a separate KOP Proxy Module: - allow to access internal ByteBuf of KafkaHeaderAndRequest, in order to allow zero-copy request magement in the Proxy - extract some static methods in order to use the same algorithm for mapping coordinators Relates to #57 Co-authored-by: Enrico Olivelli <eolivelli@apache.org>
Proxy support for KoP.
The text was updated successfully, but these errors were encountered: