Event Streaming describes the tasks required to create custom event streams for events received by your MATRIXX Digital Commerce environment. An event stream is sent to the Event Streaming Framework from the Event Stream Server running on MATRIXX Engine. The Event Stream Server provides the APIs, libraries, and other files needed to create custom event streams. The Event Streaming Framework provides connectors for sending event stream data to event stream consumers, such as Kafka and ActiveMQ.
You use the MATRIXX Digital Commerce Event Streaming feature to produce custom event streams from the events that MATRIXX Digital Commerce produces. An event stream is an ordered, unbounded, and continuous flow of events. Monitor or analyze event data in real time using an external event-handling solution by creating event streams of specific events relevant to your networks and businesses.
Use these steps as a summary of tasks required to implement event streaming in a MATRIXX Digital Commerce environment.
An Event Streaming Framework connector is required to stream events. The default connectors are listed in this section. For information about creating a custom connector, see the discussion about creating a custom connector. For information about setting the logging level for individual connectors, see the discussion about managing Event Streaming Framework logging.
The Event Stream Server and Event Streaming Framework both require administration tasks.
Reads MATRIXX Engine transaction log files and creates an output file containing events from a given _glossary/global_transaction_counter.html range. Use the -k option to recover events from Streamed Event Files (SEFs). The output file name is automatically constructed to conform to the output format.
Restreams events for all connectors within a specific GTC range, or reprocesses failed events for a Event Streaming Framework connector.
The /opt/mtx/bin/reset_cursor.py script stops the Event Streaming Framework, resets the start of the event stream to a cursor (GTC) that you specify, and then restarts the Event Streaming Framework.