diff --git a/Vagrantfile b/Vagrantfile index a4c854e..cf15497 100644 --- a/Vagrantfile +++ b/Vagrantfile @@ -38,7 +38,7 @@ Vagrant.configure("2") do |config| ansible.playbook = "ansible-playbook.yml" end # End of "config.vm.provision" - config.vm.provision "restart_kafka", type:'ansible_local', run: "never" do |restart_kafka| + config.vm.provision "restart_kafka", type:'ansible_local', run: "always" do |restart_kafka| restart_kafka.verbose = "v" restart_kafka.playbook = "ansible-playbook_restart_kafka.yml" end # End of "config.vm.restart_kafka" diff --git a/vagrant/ansible-playbook.yml b/vagrant/ansible-playbook.yml index aeb40f6..a990703 100644 --- a/vagrant/ansible-playbook.yml +++ b/vagrant/ansible-playbook.yml @@ -204,6 +204,11 @@ path: /usr/local/bin/kafka-demo.sh mode: 0755 + - name: Clearing any old zookeeper databases so ensuring a clean ZK env + file: + path: /var/lib/zookeeper/version-2/log.* + state: absent + ### ### Start Kafka services at boot time diff --git a/vagrant/ansible-playbook_restart_kafka.yml b/vagrant/ansible-playbook_restart_kafka.yml index 0770a2f..b1797ae 100644 --- a/vagrant/ansible-playbook_restart_kafka.yml +++ b/vagrant/ansible-playbook_restart_kafka.yml @@ -10,6 +10,11 @@ ### RESTART Kafka services ### + - name: Clearing any old zookeeper databases so ensuring a clean ZK env + file: + path: /var/lib/zookeeper/version-2/log.* + state: absent + - name: Make sure Kafka services are restarted service: name: "{{ item }}"