Object creation from schema for event streaming platform

1. A method, comprising:

determining, by a processing device, that an application is a consumer of one or more records of an event streaming platform including searching generated pre-compiled source code of the application to determine that the application is the consumer of the one or more records of the event streaming platform;

in response to determining that the application is the consumer of the one or more records of the event streaming platform:

determining, by the processing device, a schema that is associated with the one or more records of the event streaming platform, including:

instantiating and running a client application,

receiving by the client application, over a computer network, the one or more records from the event streaming platform, and

obtaining the schema from a schema registry based on a schema ID that is included in the one or more records;

generating, by the processing device, additional pre-compiled source code of a class for the application in view of the schema including generating a function that is associated with a property of a plain old java object (POJO), as defined by the schema; and

consuming the one or more records from the event streaming platform with the application that is compiled.

2. The method of claim 1 , wherein the event streaming platform includes a Kafka topic that comprises the one or more records.

3. The method of claim 1 , further comprising generating a helper class used to populate information from the one or more records to an instance of the class.

4. The method of claim 1 , wherein determining that the application is the consumer of the one or more records comprises:

searching the generated pre-compiled source code of the application to find at least one of a specific class, a specific interface, a specific library, or specific input parameters that is associated with the event streaming platform.

5. The method of claim 1 , wherein determining that the application is the consumer of the one or more records comprises: searching the generated pre-compiled source code of the application to find that the application comprises a call to a poll function that consumes the one or more records.

6. The method of claim 1 , wherein determining the schema of the one or more records comprises connecting to the schema registry based on a network address in the application or configuration data associated with the application.

7. The method of claim 1 , wherein generating the function includes generating the class with getter and setter properties as defined by the schema.

8. A system comprising:

a memory; and

a processing device operatively coupled to the memory, the processing device to:

determine that an application is a consumer of one or more records of an event streaming platform including searching generated pre-compiled source code of the application to determine that the application is the consumer of the one or more records of the event streaming platform;

in response to determining that the application is the consumer of the one or more records of the event streaming platform:

determine a schema that is associated with the one or more records of the event streaming platform, including to

instantiate and run a client application,

receive by the client application, over a computer network, the one or more records from the event streaming platform, and

obtain the schema from a schema registry based on a schema ID that is included in the one or more records;

generate additional pre-compiled source code of a class for the application in view of the schema, including generating a function that is associated with a property of a plain old java object (POJO), as defined by the schema; and

consume the one or more records from the event streaming platform with the application that is compiled.

9. The system of claim 8 , wherein the event streaming platform includes a Kafka topic that comprises the one or more records.

10. The system of claim 8 , wherein the processing device is further to generate a helper class that is used to populate information from the one or more records to an instance of the class.

11. The system of claim 8 , wherein to determine that the application is the consumer of the one or more records, the processing device is to: search the generated pre-compiled source code of the application to find at least one of a specific class, a specific interface, a specific library, or specific input parameters that is associated with the event streaming platform.

12. The system of claim 8 , wherein to determine that the application is the consumer of the one or more records comprises, the processing device is to: search the generated pre-compiled source code of the application to find that the application comprises a call to a poll function that consumes the one or more records.

13. The system of claim 8 , wherein to determine the schema of the one or more records, the processing device is to: connect to the schema registry based on a network address in the application or configuration data associated with the application.

14. A non-transitory computer-readable storage medium including instructions that, when executed by a processing device, cause the processing device to:

determine, by the processing device, that an application is a consumer of one or more records of an event streaming platform including searching generated pre-compiled source code of the application to determine that the application is the consumer of the one or more records of the event streaming platform;

in response to determining that the application is the consumer of the one or more records of the event streaming platform:

determine, by the processing device, a schema that is associated with the one or more records of the event streaming platform, including to:

instantiate and run a client application,

receive by the client application, over a computer network, the one or more records from the event streaming platform, and

obtain the schema from a schema registry based on a schema ID that is included in the one or more records;

generate, by the processing device, additional pre-compiled source code of a class for the application in view of the schema including generating a function that is associated with a property of a plain old java object (POJO), as defined by the schema; and

consume the one or more records from the event streaming platform with the application that is compiled.

15. The non-transitory computer-readable storage medium of claim 14 , wherein the event streaming platform includes a Kafka topic that comprises the one or more records.

16. The non-transitory computer-readable storage medium of claim 14 , wherein the processing device is further to generate a helper class that is used to populate information from the one or more records to an instance of the class.

17. The non-transitory computer-readable storage medium of claim 14 , wherein to determine that the application is the consumer of the one or more records, the processing device is to: search the generated pre-compiled source code of the application to find at least one of a specific class, a specific interface, a specific library, or specific input parameters that is associated with the event streaming platform.

18. The non-transitory computer-readable storage medium of claim 14 , wherein to determine that the application is the consumer of the one or more records comprises, the processing device is to: search the generated pre-compiled source code of the application to find that the application comprises a call to a poll function that consumes the one or more records.

19. The non-transitory computer-readable storage medium of claim 14 , wherein to determine the schema of the one or more records, the processing device is to: connect to the schema registry based on a network address in the application or configuration data associated with the application.