Spring Java Kafka Generator

This generator enables the deployment of your OpenLegacy Hub project as an Apache Kafka service in a Java runtime environment. The output is a low-code Spring Boot project, which mirrors the contract of the generated Hub project. Each method within the Hub project is transformed into a Kafka consumer, responsible for processing messages from a Kafka Topic and executing the associated logic.

Once deployed and running, to incorporate the latest changes from the Hub project—such as newly added methods, removed methods, or modifications to input/output fields—simply stop and restart the service.

For projects utilizing the OPZ provider, ensure the OPZ file is updated with the new version before restarting the service to reflect the changes

Consumer Configuration:

• Type:
  • Consume Only - Retrieves a message from the Consumer Topic and executes the flow logic.
  • Consume Produce - Retrieves a message from the Consumer Topic, processes it, and publishes the result to the Producer Topic.
• Consumer Topic: The Kafka Topic from which messages are consumed.
• Producer Topic : The Kafka Topic where processed output messages are published.
• Error Handling: Defines the behavior when message processing fails.
  • Commit: No action. The consumer proceeds to the next message.
  • No Commit: Retries the message a few times before failing the consumer if unsuccessful.
  • Dead Letter Queue (DLQ): Moves the failed message to a designated error Topic (DLQ) and continues to the next message.
• Dead Letter Queue (DLQ): If DLQ is selected in the error handling strategy, specify the Kafka Topic for error messages here.