Data plane reduction for eventing components
Systems and methods are described for configuring a data plane of an event streaming platform. An example method includes receiving a topology definition describing a topology of an event streaming platform, and generating a representation of a data plane of the event streaming platform.
1. A method comprising:
receiving a topology definition describing a topology of an event streaming platform;
generating, based on the topology definition, a representation of a data plane of the event streaming platform; and
generating, by a processing device, a simplified data plane pathway based on the representation, wherein the simplified data plane pathway reduces intermediate hops between an event source and a final event destination.
2. The method of claim 1 , further comprising generating an event message at the event source and sending the event message directly to the final event destination in a single hop.
3. The method of claim 2 , wherein generating the event message comprises generating a hypertext transfer protocol (HTTP) CloudEvent message.
4. The method of claim 1 , further comprising receiving the topology definition describing a series of eventing components.
5. The method of claim 1 , wherein the event streaming platform is at least partially implemented as a Knative event streaming platform.
6. The method of claim 1 , further comprising generating a plurality of data plane pathways which includes the simplified data plane pathway, wherein each ingress service of the topology is associated with one of the plurality of data plane pathways.
7. The method of claim 1 , wherein the topology of the event streaming platform comprises an event broker to implement an event filter, and wherein generating the simplified data plane pathway comprises implementing the event filter at the event source.
8. The method of claim 1 , wherein the simplified data plane pathway reduces the intermediate hops described by the topology definition.
9. A system comprising:
a memory; and
a processing device operatively coupled to the memory, the processing device to:
receive a topology definition describing a topology of an event streaming platform;
generate, based on the topology definition, a representation of a data plane of the event streaming platform; and
generate a simplified data plane pathway based on the representation, wherein the simplified data plane pathway reduces intermediate hops between an event source and a final event destination.
10. The system of claim 9 , wherein the processing device is further to generate a hypertext transfer protocol (HTTP) CloudEvent message at the event source and send the HTTP CloudEvent message directly to the final event destination in a single hop.
11. The system of claim 9 , wherein the processing device is further to receive the topology definition describing a series of eventing components.
12. The system of claim 9 , wherein the event streaming platform is at least partially implemented as a Knative event streaming platform.
13. The system of claim 9 , wherein the processing device is further to generate a plurality of data plane pathways which includes the simplified data plane pathway, wherein each ingress service of the topology is associated with one of the plurality of data plane pathways.
14. The system of claim 9 , wherein the topology of the event streaming platform comprises an event broker to implement an event filter, and wherein to generate the simplified data plane pathway comprises to implement the event filter at the event source.
15. The system of claim 9 , wherein the simplified data plane pathway reduces the intermediate hops described by the topology definition.
16. A non-transitory computer-readable medium, having instructions stored thereon which, when executed by a processing device, cause the processing device to:
receive a topology definition describing a topology of an event streaming platform;
generate, based on the topology definition, a representation of a data plane of the event streaming platform; and
generate, by the processing device, a simplified data plane pathway based on the representation, wherein the simplified data plane pathway eliminates intermediate hops between an event source and a final event destination.
17. The non-transitory computer-readable medium of claim 16 , further comprising instructions to cause the processing device to generate a hypertext transfer protocol (HTTP) CloudEvent message at the event source and send the HTTP CloudEvent message directly to the final event destination in a single hop.
18. The non-transitory computer-readable medium of claim 16 , further comprising instructions to cause the processing device to receive the topology definition describing a series of eventing components.
19. The non-transitory computer-readable medium of claim 16 , wherein the event streaming platform is at least partially implemented as a Knative event streaming platform.
20. The non-transitory computer-readable medium of claim 16 , wherein the topology of the event streaming platform comprises an event broker configured to implement an event filter, and wherein to generate the simplified data plane pathway comprises to implement the event filter at the event source.