High-throughput proxy-based access to event streaming platforms

A server, configured to:

• maintain a pool of connections to a cloud-based stream-processing service;
• establish, while maintaining the pool of connections, a client connection with a client device;
• obtain a producer connection from the pool of connections;
• receive, while maintaining the pool of connections and via the client connection, a remote procedure call (RPC) message from the client device;
• generate, based on the RPC message and service information for the cloud-based stream-processing service, a modified message;
• and
• provide, via the producer connection, the modified message to the cloud-based stream-processing service for distribution to one or more subscribers from the cloud-based stream-processing service.

A proxy server, configured to:

• maintain a pool of connections to a cloud-based stream-processing service;
• establish, while maintaining the pool of connections, a client connection with a client device;
• receive, while maintaining the pool of connections and via the client connection, subscription information for the client device;
• obtain a consumer connection from the pool of connections;
• obtain, via the consumer connection, a message associated with the subscription information from the cloud-based stream-processing service;
• generate a remote procedure call (RPC) message based on the message;
• and
• provide, via the client connection, the RPC message to the client device.