Legacy environment streaming

1. A method for streaming data in a legacy mainframe environment, the method comprising:

receiving, at a KAFKA streaming platform abstraction layer interface, production data from a first publisher application;

selecting a producer instance to receive the production data;

configuring the selected producer instance with a first set of configuration parameters from at least one producer library;

communicating the first publication data to the selected producer instance; and

forwarding the first publication data to a KAFKA streaming platform cluster in operable communication with a consumer instance.

2. The method of claim 1 wherein:

the selected producer instance operates in accord with a first encoding scheme,

the consumer instance operates in accord with a second encoding scheme that is different than the first encoding scheme, and

the method further includes executing an encoding translation procedure to transcode the production data from the first encoding scheme to the second encoding scheme.

3. The method of claim 1 wherein communicating the first publication data includes:

establishing a queue associated with the selected producer instance,

placing the first publication data in the established queue, and

communicating the first publication data from the established queue to the selected producer instance in a priority-based order.

4. The method of claim 1 further comprising executing a serialization procedure to transform the publication data to a serialized format before communicating the publication data to the selected producer instance.

5. The method of claim 1 wherein configuring the selected producer instance with the first set of configuration parameters includes:

receiving at least one instance-specific configuration parameter from an instance-specific repository, and

updating the selected producer instance in accord with the at least one instance-specific configuration parameter.

6. The method of claim 1 wherein configuring the selected producer instance with the first set of configuration parameters includes:

receiving at least one global configuration parameter from a global configuration repository,

updating the selected producer instance in accord with the at least one global configuration parameter,

wherein the at least one global configuration parameter is applicable to a plurality of producer instances and is selected from the group consisting of broker internet protocol (IP) address and port configuration data.

7. The method of claim 1 further comprising forwarding the publication data to a first consumer application.

8. The method of claim 7 further comprising executing a deserialization procedure to deserialize the publication data before forwarding the publication data to the first consumer application.

9. A method for streaming data in a legacy mainframe environment, the method comprising:

receiving at an interface a subscription request from a first consumer application;

selecting a consumer instance to provide production data to the first consumer application;

configuring the selected consumer instance with a first set of configuration parameters from at least one consumer library;

receiving at the consumer instance the production data from a KAFKA streaming platform cluster; and

forwarding the production data to the first consumer application.

10. The method of claim 9 wherein receiving the subscription request includes registering a call back routine with the selected consumer instance.

11. The method of claim 9 further comprising executing a deserialization procedure to deserialize the production data before forwarding the production data to the first consumer application.

12. The method of claim 11 further comprising:

establishing a queue associated with the first selected consumer instance,

placing the production data in the established queue, and

communicating the production data from the queue to the selected consumer instance in a priority-based order.

13. The method of claim 9 wherein configuring the selected consumer instance with the first set of configuration parameters includes:

receiving at least one instance-specific configuration parameter from an instance-specific repository, and

updating the selected consumer instance in accord with the at least one instance-specific configuration parameter.

14. The method of claim 9 wherein configuring the selected consumer instance with the first set of configuration parameters includes:

receiving at least one global configuration parameter from a global configuration repository,

updating the selected producer instance in accord with the at least one global configuration parameter,

wherein the at least one global configuration parameter is applicable to a plurality of consumer instances and is selected from the group consisting of broker internet protocol (IP) address and port data.

15. A system for streaming data in a legacy mainframe environment, the system comprising:

a KAFKA streaming platform abstraction layer interface in communication with a first publisher application;

at least one producer instance configured in accord with a configuration parameter from at least one producer configuration library, wherein the KAFKA streaming platform abstraction layer interface selects a producer instance to receive publication data from the first publisher application;

at least one consumer instance configured in accord with a configuration parameter from at least one consumer configuration library, and

a KAFKA streaming platform client layer interface configured to:

forward the publication data from the selected producer instance to a KAFKA streaming platform cluster, and

forward consumer data based on the publication data from the KAFKA streaming platform cluster to the consumer instance, wherein the consumer instance is configured to communicate the consumer data to a first consumer application.

16. The system of claim 15 wherein:

the first publisher application operates in accordance with a first encoding scheme,

the first consumer application operates in accord with a second encoding scheme that is different than the first encoding scheme, and

the system further includes a translation module configured to execute an encoding translation procedure to transcode the production data from the first encoding scheme to the second encoding scheme.

17. The system of claim 15 wherein the KAFKA streaming platform abstraction layer interface is further configured to perform a serialization procedure to transform the publication data to a serialized format before communicating the publication data to the selected producer instance.

18. The system of claim 17 wherein the KAFKA streaming platform abstraction layer interface is further configured to perform a deserialization procedure to deserialize the consumer data before communicating the consumer data to the first consumer application.

19. The system of claim 15 further comprising a global configuration repository storing configuration parameters applicable to a plurality of producer instances or a plurality of consumer instances.

20. The system of claim 15 further comprising an instance-specific repository storing configuration parameters applicable to a specific producer instance or a specific consumer instance.