Page History

...

The diagram below shows the overall architecture of the system.

Image AddedImage Removed

1. The External Application makes a POST REST call to the Kafka Integration App. 
   The contents of the REST call could be - App name, Event Type and consumer group-id.
2. If there is no listener for this event type the Event Manager module within the App will register a listener for the specific event with ONOS. 
   If there is a listener already, the event manager will not create a listener.
3. The response for the POST will be 200 ok instead of 201 created. This is because the resource is created on an
   external entity and we would like to send connectivity information about the Kafka server in the response. The response could contain server Ip, port etc, needed for connectivity.
4. The external app would then use this information to connect to the Kafka server and register itself as a consumer for the topic it had registered earlier.
5. At some later point in time we receive our first event from ONOS. The Event Manager module will pick up the event. 
   It will convert the data format to the common GPB format and Marshall the data using the GPB library. The Data is then passed along to the Kafka Manager. 
6. The Kafka Manager module will publish the event to the topic. 
7. The external app will receive the event in GPB defined message format. 

...