# Ansible  - KAFKA Integration

**URL:** <https://forum.ansible.com/t/ansible-kafka-integration/36707>\
**Category:** Ansible Project\
**Created:** [June 9, 2022, 12:30pm UTC](https://forum.ansible.com/t/ansible-kafka-integration/36707 "2022-06-09T12:30:24Z")\
**Posts on this page:** 4\
**Page:** 1

<div class="post-metadata">

**Author:** ![Madhan\_Sagadevan](https://avatars.discourse-cdn.com/v4/letter/m/85f322/32.png) [@Madhan\_Sagadevan](https://forum.ansible.com/u/Madhan_Sagadevan)\
**Post date:** [June 9, 2022, 12:30pm UTC](https://forum.ansible.com/t/ansible-kafka-integration/36707/1 "2022-06-09T12:30:24Z")

</div>

Hello,

I understand we can install/deploy KAFKA using Ansible (Playbook). I am not sure if Ansible can be used as a PULL mechanism for fetching KAFKA (Consumer) Topic on quick interval like every 15 mins.

Thanks,  
Madhan

---

<div class="post-metadata">

**Author:** ![Jorge\_Rua1](https://avatars.discourse-cdn.com/v4/letter/j/a87d85/32.png) [@Jorge\_Rua1](https://forum.ansible.com/u/Jorge_Rua1)\
**Post date:** [June 10, 2022, 10:31am UTC](https://forum.ansible.com/t/ansible-kafka-integration/36707/2 "2022-06-10T10:31:49Z")

</div>

This is an extremely interesting question. Although ansible is designed to work in push mode, would be possible to push the payload to a queue so an ansible agent subscribed to that queue can fetch that later on?

Thanks,

---

<div class="post-metadata">

**Author:** ![Chiku](https://avatars.discourse-cdn.com/v4/letter/c/3ab097/32.png) [@Chiku](https://forum.ansible.com/u/Chiku)\
**Post date:** [June 10, 2022, 10:43am UTC](https://forum.ansible.com/t/ansible-kafka-integration/36707/3 "2022-06-10T10:43:56Z")

</div>

There is ansible-pull command if your concern is about pull strategy  
[https://docs.ansible.com/ansible/latest/cli/ansible-pull.html](https://docs.ansible.com/ansible/latest/cli/ansible-pull.html)

---

<div class="post-metadata">

**Author:** ![Jorge\_Rua1](https://avatars.discourse-cdn.com/v4/letter/j/a87d85/32.png) [@Jorge\_Rua1](https://forum.ansible.com/u/Jorge_Rua1)\
**Post date:** [June 10, 2022, 11:10am UTC](https://forum.ansible.com/t/ansible-kafka-integration/36707/4 "2022-06-10T11:10:12Z")

</div>

Yes and No,

AFAIK ansible-pull works by pointing out to a vcs repo where playbooks exist. I was thinking on something slightly different, instead of pulling playbooks so they can be applied locally, pulling the payload that is sent from a controller machine to a queue. Does that make sense?