6 Commits

Author SHA1 Message Date
Shravan Ambati
5a11e17c06 Refactored Kafka Application to simplify dependencies
1. Fixed a Bug in KafkaProducer. Without this fix the App will not send data in GPB format.
2. Added two new services - KafkaProducerService and KafkaConfigService.
3. Fixed a TODO in the register API to return Kafka server information.
4. Removed the use of LeadershipService and ClusterService, since we are not ready for clustering yet.

Change-Id: If20ef5238bb4629af0c6769129494eb44abf1d3c
2016-08-08 23:33:48 +00:00
Sanjana Agarwal
cb4a3db30b Made changes as per comments.
kafkaProducer is now non-static.

TODO: KafkaPublisherManager Service and not Singleton.
Kafka event publishing.

Change-Id: I5ec20a6e4950c38e822468d343521ab77475b7d3
2016-07-19 20:56:08 +00:00
Shravan Ambati
1e8471e9ad Intial Stub code for the Cluster features in Kafka Application.(patchset #4)
Stub Implementation of KafkaStorage Service.

Change-Id: Iad929a8f1b13149583c9526b41e8f1a3a829fa1e
2016-07-15 19:02:06 +00:00
Sanjana Agarwal
eb9f0c5eff Kafka Codec Integration
Made changes as per the comments on patch set 2.
Made changes as per comments on patch set 3.
Made further changes and event subscription works absolutely fine now.

Change-Id: Icd20195f6c0e045d14beb73584069d486ab9290c
2016-06-17 18:01:27 +00:00
Brian O'Connor
1b2aea88c0 Removing gratuitous relativePath from pom.xmls
The default value for relativePath is: ../pom.xml

Change-Id: I1f5e5e6bfa1e91fcddae4f8cb8ab0c00c276e6b0
2016-06-16 07:05:31 +00:00
Shravan Ambati
bb6b4458cb Kafka Integration Application (Fix Javadoc errors + review comments)
1. Refactored the application into two java projects api and app as per convention
2. Deleted the onos-app-gpb project. The proto files are consolidated in the
   incubator-protobuf project as per suggestions.
3. Some code to translate ONOS Event pojo messages to GPB format.
4. Implementation of Subscribe and Unsubscribe APIs.
5. Minor changes due to review comments from 9212 and 9053
6. Refactored the proto fileso that its a 1:1 mapping between the core type to proto message.

Change-Id: I2bcc0de96150f838ccfe9e49293fe61d94062628
2016-05-31 18:06:28 -07:00