|
52 | 52 | httpUrl: "http://{{ hostvars[groups['pulsar'][0]].private_ip }}:8080/"
|
53 | 53 | pulsarVersion: "1.21.0-incubating"
|
54 | 54 |
|
55 |
| - - name: Download Pulsar |
| 55 | + - name: Create Pulsar directory |
56 | 56 | file:
|
57 | 57 | path: "/opt/pulsar"
|
58 | 58 | state: directory
|
59 |
| - - get_url: |
60 |
| - url: https://dist.apache.org/repos/dist/dev/incubator/pulsar/pulsar-{{ pulsarVersion }}-candidate-3/apache-pulsar-{{ pulsarVersion }}-bin.tar.gz |
61 |
| - dest: /tmp/pulsar.tgz |
62 |
| - - command: tar --strip-components=1 -xvf /tmp/pulsar.tgz |
63 |
| - args: |
64 |
| - chdir: /opt/pulsar |
65 |
| - |
| 59 | + - name: Download Pulsar binary package |
| 60 | + unarchive: |
| 61 | + src: https://github.com/apache/incubator-pulsar/releases/download/v{{ pulsarVersion }}/apache-pulsar-{{ pulsarVersion }}-bin.tar.gz |
| 62 | + remote_src: yes |
| 63 | + dest: /opt/pulsar |
| 64 | + extra_opts: ["--strip-components=1"] |
66 | 65 | - set_fact:
|
67 | 66 | private_ip: "{{ hostvars[inventory_hostname]['ansible_default_ipv4']['address'] }}"
|
68 | 67 | max_heap_memory: "24g"
|
|
71 | 70 | src: "templates/pulsar_env.sh"
|
72 | 71 | dest: "/opt/pulsar/conf/pulsar_env.sh"
|
73 | 72 |
|
74 |
| -- name: Setup ZooKeeper |
| 73 | +- name: ZooKeeper setup |
75 | 74 | hosts: zookeeper
|
76 | 75 | connection: ssh
|
77 | 76 | become: true
|
|
101 | 100 | state: restarted
|
102 | 101 | daemon_reload: yes
|
103 | 102 | name: "zookeeper"
|
104 |
| - - command: > |
| 103 | + - name: Initialize cluster metadata |
| 104 | + run_once: true |
| 105 | + command: > |
105 | 106 | bin/pulsar initialize-cluster-metadata --cluster local
|
106 | 107 | --zookeeper localhost:2181
|
107 | 108 | --global-zookeeper localhost:2181
|
|
111 | 112 | chdir: /opt/pulsar
|
112 | 113 | when: groups['zookeeper'][0] == inventory_hostname
|
113 | 114 |
|
114 |
| -- name: Setup Bookkeeper |
| 115 | +- name: Bookkeeper setup |
115 | 116 | hosts: pulsar
|
116 | 117 | connection: ssh
|
117 | 118 | become: true
|
|
128 | 129 | daemon_reload: yes
|
129 | 130 | name: "bookkeeper"
|
130 | 131 |
|
131 |
| -- name: Setup Pulsar |
| 132 | +- name: Pulsar setup (part 2) |
132 | 133 | hosts: pulsar
|
133 | 134 | connection: ssh
|
134 | 135 | become: true
|
|
147 | 148 |
|
148 | 149 | - name: Get Maven version
|
149 | 150 | hosts: localhost
|
| 151 | + become: false |
150 | 152 | tasks:
|
151 | 153 | - shell: >
|
152 | 154 | cat ../../pom.xml | xmllint --format - \
|
153 | 155 | | sed "s/xmlns=\".*\"//g" | xmllint --stream --pattern /project/version --debug - \
|
154 | 156 | | grep -A 2 "matches pattern" | grep text | sed "s/.* [0-9] //g"
|
155 | 157 | register: maven_version
|
156 | 158 | - set_fact:
|
157 |
| - benchmark_version: "{{ maven_version.stdout }}" |
| 159 | + benchmark_version: "{{ maven_version.stdout }}" |
158 | 160 |
|
159 |
| -- name: Setup Pulsar client |
| 161 | +- name: Pulsar client setup |
160 | 162 | hosts: client
|
161 | 163 | connection: ssh
|
162 | 164 | become: true
|
|
174 | 176 | mv /opt/openmessaging-benchmark-0.0.1-SNAPSHOT /opt/benchmark
|
175 | 177 | - name: Configure service URL
|
176 | 178 | lineinfile:
|
177 |
| - dest: /opt/benchmark/driver-pulsar/pulsar.yaml |
178 |
| - regexp: '^ serviceUrl \: ' |
179 |
| - line: ' serviceUrl : {{ serviceUrl }}' |
| 179 | + dest: /opt/benchmark/driver-pulsar/pulsar.yaml |
| 180 | + regexp: '^ serviceUrl \: ' |
| 181 | + line: ' serviceUrl : {{ serviceUrl }}' |
180 | 182 | - name: Configure http URL
|
181 | 183 | lineinfile:
|
182 |
| - dest: /opt/benchmark/driver-pulsar/pulsar.yaml |
183 |
| - regexp: '^ httpUrl : ' |
184 |
| - line: ' httpUrl : {{ httpUrl }}' |
| 184 | + dest: /opt/benchmark/driver-pulsar/pulsar.yaml |
| 185 | + regexp: '^ httpUrl : ' |
| 186 | + line: ' httpUrl : {{ httpUrl }}' |
185 | 187 | - name: Configure http URL
|
186 | 188 | lineinfile:
|
187 | 189 | dest: /opt/benchmark/bin/benchmark
|
188 | 190 | regexp: '^JVM_MEM='
|
189 | 191 | line: 'JVM_MEM="-Xms24G -Xmx24G -XX:+UseG1GC -XX:MaxGCPauseMillis=10 -XX:+ParallelRefProcEnabled -XX:+UnlockExperimentalVMOptions -XX:+AggressiveOpts -XX:+DoEscapeAnalysis -XX:ParallelGCThreads=32 -XX:ConcGCThreads=32 -XX:G1NewSizePercent=50 -XX:+DisableExplicitGC -XX:-ResizePLAB -XX:+PerfDisableSharedMem -XX:+AlwaysPreTouch -XX:-UseBiasedLocking"'
|
190 | 192 |
|
191 |
| - |
192 | 193 | - name: Hosts addresses
|
193 | 194 | hosts: localhost
|
194 | 195 | become: false
|
|
0 commit comments