-
Notifications
You must be signed in to change notification settings - Fork 4
/
provision.yml
102 lines (91 loc) · 3.41 KB
/
provision.yml
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
---
# create kafka server and client instances
- name: create kafka instances
hosts: localhost
vars_files:
- group_vars/kafka/vars
vars:
count: '{{ cluster_size - 1 }}'
tasks:
# sudo user sanitation
- name: get local system users
slurp:
src: /etc/passwd
register: getusers
- name: create system user list
set_fact:
system_users: "{{ getusers['content'] | b64decode | regex_replace(' ', '') | split() | map('regex_replace', '^([^:]+):.*', '\\1') | list }}"
- name: check if {{ sudo_username }} user already exist
fail:
msg: |
[FATAL] illegal username provided --> {{ sudo_username }}
The user already exist on the system. Please redeploy the Marketplace app using a non-system user for the sudo user value.
Do not use the following users,
{{ system_users }}
when: "sudo_username in system_users or sudo_username == 'kafka'"
# generate playbook secrets
- name: generating playbook secrets
lineinfile:
insertafter: EOF
path: group_vars/kafka/vars
line: |
truststore_password: {{ lookup('password', '/dev/null length=25 chars=ascii_letters,digits') }}
keystore_password: {{ lookup('password', '/dev/null length=25 chars=ascii_letters,digits') }}
ca_password: "{{ lookup('password', '/dev/null length=25 chars=ascii_letters,digits') }}"
sudo_password: {{ lookup('password', '/dev/null length=25 chars=ascii_letters,digits') }}
no_log: true
- name: creating kafka servers
linode.cloud.instance:
label: '{{ instance_prefix }}{{ item | int + 1 }}-{{ uuid }}'
api_token: '{{ token }}'
type: '{{ type }}'
region: '{{ region }}'
image: '{{ image }}'
root_pass: '{{ root_pass }}'
authorized_keys: '{{ ssh_keys }}'
private_ip: true
stackscript_id: 1382315
ua_prefix: 'marketplace-kafka-occ'
tags: '{{ linode_tags }}'
state: present
with_sequence: count='{{ count }}'
- name: get info about the instances
linode.cloud.instance_info:
api_token: '{{ token }}'
label: '{{ instance_prefix }}{{ item }}-{{ uuid }}'
register: info
with_sequence: count='{{ cluster_size }}'
- name: update group_vars
blockinfile:
path: ./group_vars/kafka/vars
marker: "# {mark} INSTANCE VARS"
block: |
#jinja2: trim_blocks:False
kafka_data:
server:
{%- for count in range(cluster_size) %}
- kafka{{ count + 1 }}:
instance:
hostname: kafka{{ count + 1 }}
ip_pub1: {{ info.results[count].instance.ipv4[0] }}
ip_priv1: {{ info.results[count].instance.ipv4[1] }}
{%- endfor %}
- name: add kafka nodes to inventory
blockinfile:
path: ./hosts
marker: "# {mark} KAFKA INSTANCES"
block: |
#jinja2: trim_blocks:False
[kafka]
localhost ansible_connection=local user=root role='controller and broker'
{%- for count in range(cluster_size - 1) %}
{{ info.results[count + 1].instance.ipv4[0] }} {% if count < controller_count - 1 %}role='controller and broker'{%else%}role='broker only'{%endif%}
{%- endfor %}
- name: wait for port 22 to become open
wait_for:
port: 22
host: '{{ item.instance.ipv4[0] }}'
search_regex: OpenSSH
delay: 10
connection: local
with_items: "{{ info.results }}"