判断kafka服务是否启动，并尝试启动kakfa，启动kafka失败开始安装kafka、jdk，添加kafka server定时删除脚本，完成以上步骤清理安装包

---

- name: check kafka service shell: "ps -ef|grep kafka|grep -v |awk '{print $2}'"

register: kafka_process_result

- name: try to start kafka service

shell: "/usr/local/kafka/{{brokers.package_name}}/bin/kafka-server-start.sh -daemon /usr/local/kafka/{{brokers.package_name}}/config/kraft/server.properties"

ignore_errors: true

register: kafka_start_process

when: kafka_process_result.stdout_lines==[]

- fail:

msg: "try to start kafka fail, start setup kafka later"

register: kafka_setup

ignore_errors: true

when: kafka_start_process is not skip and kafka_start_process is failure

- name: setup kafka

block:

- name: copy packages

copy: src: "{{copy_path}}/{{brokers.package_name}}.tgz"

dest: "/usr/local/kafka/"

owner: root

group: root

mode: 0755

ignore_errors: yes

- name: unzip kafka package

shell: cd /usr/local/kafka && tar -zxvf {{brokers.package_name}}.tgz

- name: copy server.properties

template:

src=server.kraft.properties.j2

dest=/usr/local/kafka/{{brokers.package_name}}/config/kraft/server.properties

- name: copy kafka service

template:

src=kafka.service.j2

dest=/usr/lib/systemd/system/kafka.service

- name: enable kafka service

shell: systemctl enable kafka

- name: copy jdk

copy:

src: "{{copy_path}}/{{jdk.version}}.tar"

dest: "/usr/local"

owner: root

group: root

mode: 0755

ignore_errors: yes

- name: unzip jdk

shell: cd /usr/local && tar -xvf {{jdk.version}}.tar

- name: set JAVA_HOME

lineinfile:

dest=/etc/profile insertafter="{{item.position}}" line="{{item.value}}" state=present

with_items:

- {position: EOF, value: "export JAVA_HOME=/usr/local/{{jdk.version}}"}

- {position: EOF, value: "export PATH=$JAVA_HOME/bin:$PATH"}

- name: copy jdk to ~/.bashrc

lineinfile: dest=~/.bashrc insertafter="{{item.position}}" line="{{item.value}}" state=present

with_items:

- {position: EOF, value: "export JAVA_HOME=/usr/local/{{jdk.version}}"}

- {position: EOF, value: "export PATH=$JAVA_HOME/bin:$PATH"}

- name: source profile

shell: source /etc/profile && source ~/.bashrc

when: jdk_setup is not skip

- name: clean install package

shell: rm -f /usr/local/kafka/{{brokers.package_name}}.tgz

- name: copy kafka clean log script

template:

src: clean_kafka_logs.j2

dest: /usr/local/kafka/{{brokers.package_name}}/bin/clean_kafka_logs.sh

owner: root

group: root

mode: 0777

rescue:

- name:

shell: "echo setup end"

when: kafka_setup is not skip

 

 

配置kafka log地址，初始化kafka集群，清除集群初始化脚本，添加清除server日志定时任务，启动kafka服务

- name: mkdir kafka-logs

shell: mkdir -p /usr/local/kafka/{{brokers.package_name}}/kafka-logs

delegate_to: "{{item}}"

with_items: "{{groups['middleware']}}"

 

- name: set JAVA_HOME

shell: export JAVA_HOME=/usr/local/{{jdk.version}} && export PATH=$JAVA_HOME/bin:$PATH

 

- name: create meta-data uuId

shell: source /etc/profile && source ~/.bashrc && sh /usr/local/kafka/{{brokers.package_name}}/bin/kafka-storage.sh random-uuid

register: kafka_metadata_uuId

 

- name: copy init kafka cluster script

template:

src: init_kafka_cluster.j2

dest: /tmp/init_kafka_cluster.sh

owner: root

group: root

mode: 0777

delegate_to: "{{item}}"

with_items: "{{groups['middleware']}}"

 

- name: init kafka cluster

shell: source /etc/profile && source ~/.bashrc && sh /tmp/init_kafka_cluster.sh

delegate_to: "{{item}}"

with_items: "{{groups['middleware']}}"

 

- name: clean kafka cluster script

shell: rm -f /tmp/init_kafka_cluster.sh

delegate_to: "{{item}}"

with_items: "{{groups['middleware']}}"

- name: stop old kafka service

shell: service kafka stop

ignore_errors: yes

delegate_to: "{{item}}"

with_items: "{{groups['middleware']}}"

- name: delete old kafka service

shell: rm -f /usr/lib/systemd/system/kafka.service

ignore_errors: yes

delegate_to: "{{item}}"

with_items: "{{groups['middleware']}}"

- name: copy kafka service

template: src=kafka.service.j2 dest=/usr/lib/systemd/system/kafka.service

delegate_to: "{{item}}"

with_items: "{{groups['middleware']}}"

- name: reload systemctl deamon

shell: systemctl daemon-reload

delegate_to: "{{item}}"

with_items: "{{groups['middleware']}}"

- name: enable kafka service

shell: systemctl enable kafka

delegate_to: "{{item}}"

with_items: "{{groups['middleware']}}"

 

- name: start kafka service

shell: service kafka restart

delegate_to: "{{item}}"

with_items: "{{groups['middleware']}}"

 

可通过以下语句执行kafka部署初始化工作

ansible-playbook -i hosts playbook/kafka.yml --tag install

ansible-playbook -i hosts playbook/kafka.yml --tag init --limit ipaddress