blob: 97fe229a23a6e986893e2566ca50b99e56fa5a88 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
|
.. This work is licensed under a Creative Commons Attribution 4.0 International License.
.. http://creativecommons.org/licenses/by/4.0
Installation
============
Environment
-----------
Message Router is developed using Kafka, Zookeeper and Java. AJSC framework is
used to create the REST service and Docker was used to package the service.
Steps
-----
Message Router has 3 docker containers. Dmaap\_container,
kafka\_container and zookeeper\_container. Zookeeper runs on 172.18.0.2,
kafka runs on 172.18.0.3 and dmaap on 172.18.0.4.
1) Clone message service repo
.. code-block::
git clone http://gerrit.onap.org/r/dmaap/messagerouter/messageservice
2) copy messageservice/bundleconfig-local/etc/appprops/MsgRtrApi.properties
to /var/tmp directory
3) In /var/tmp/MsgRtrApi.properties, change value of below variables as
shown below:
.. code-block::
config.zk.servers=172.18.0.2 (Change as per where ZooKeepeer is deployed)
kafka.metadata.broker.list=172.18.0.3:9092 (Change as per where Kafka is deployed)
4) Install docker and docker-compose
5) Go to messageservice/src/main/resources/docker-compose and run:
.. code-block::
docker-compose up # add -d argument to start process as a daemon (background process)
This should start 3 containers.
6) Run docker ps. It should show 3 containers.
|image0|
.. |image0| image:: docker.png
Testing
-------
- For publishing, create a sample.txt file with some content in the
directory where you will run below rest api. Run below rest api:
.. code-block::
curl -H "Content-Type:text/plain" -X POST -d @sample.txt http://172.18.0.4:3904/events/TestTopic1
- For subscribing, run below rest api:
.. code-block::
curl -H "Content-Type:text/plain" -XGET http://172.18.0.4:3904/events/TestTopic1/CG1/C1?timeout=1000
Note: You will only receive messages which have been published after
you have subscribed to a topic.
Steps for local development and test
------------------------------------
On Intel dev machine, in terminal (> indicates prompt) :
1) Build kafka11aaf
.. code-block::
> git clone https://gerrit.onap.org/r/dmaap/kafka
> cd kafka11aaf
> mvn clean install -Pdocker
2) Build messageservice
.. code-block::
> git clone https://gerrit.onap.org/r/dmaap/messagerouter/messageservice
(Note: anonymous http, can't push changes)
> cd messageservice
> mvn clean install -Pdocker
3) Run tests
.. code-block::
> cp bundleconfig-local/etc/appprops/MsgRtrApi.properties /var/tmp/
- edit /var/tmp/MsgRtrApi.properties
config.zk.servers=zookeeper
kafka.metadata.broker.list=kafka:9092
- docker-compose network maps service name(zookeeper, kafka) to IP
- set docker preferences/file sharing to access /var/tmp
> cd src/main/resources/docker-compose
- edit docker-compose.yml
- remove "nexus3.onap.org:10001/" from kafka and dmaap image names to
use local images
> docker-compose up -d
- create sample.txt file (as above)(content of file not important)
> curl -H "Content-Type:text/plain" -X POST -d @sample.txt http://localhost:3904/events/TestTopic1
On Arm:
1) Build kafka11aaf
.. code-block::
> git clone https://gerrit.onap.org/r/dmaap/kafka
> cd kafka11aaf
> mvn clean install -Pdocker -Ddocker.pull.registry=docker.io
- ensure we pull Arm version of base image
2) Build messageservice
.. code-block::
> git clone https://gerrit.onap.org/r/dmaap/messagerouter/messageservice
- anonymous http, can't push changes
> cd messageservice
> mvn clean install -Pdocker -Ddocker.pull.registry=docker.io
- ensure we pull Arm version of base image
3) Run tests
.. code-block::
> cp bundleconfig-local/etc/appprops/MsgRtrApi.properties /var/tmp/
- edit /var/tmp/MsgRtrApi.properties
config.zk.servers=zookeeper
kafka.metadata.broker.list=kafka:9092
- docker-compose network maps service name(zookeeper, kafka) to IP
- set docker preferences/file sharing to access /var/tmp
> cd src/main/resources/docker-compose
- edit docker-compose.yml
- remove "nexus3.onap.org:10001/" from from kafka and dmaap image names to
use local images
- replace 'nexus3.onap.org:10001/onap/dmaap/zookeeper:1.0.0' with
multi-platform 'zookeeper'
> docker-compose up -d
- create sample.txt file (as above)(content of file not important)
> curl -H "Content-Type:text/plain" -X POST -d @sample.txt http://localhost:3904/events/TestTopic1
|
