Ansible playbook pentru a posta un mesaj în subiectul Kafka

Cartea de joc 1:
---
- nume: mesaj în subiect
  gazde: web1
  deveni: da
  sarcini:
    - nume: postați mesaj
      aştepta:
        shell: „/usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic”
        raspunsuri:
          Întrebare:
            - "Bună"
        

Playbook 2:

- nume: mesaj în subiect
  gazde: web1
  gather_facts: false
  sarcini:
    - nume: postați mesaj
      coajă:
        comandă: /usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic
        raspunsuri:                    
          (?i)Mesaj: „Salut din Playbook”
  

Am încercat cu cele două manuale de mai sus și am ajuns cu câteva erori. Nu se poate găsi o soluție adecvată pentru asta. [introduceți descrierea imaginii aici][1]

root@ip-172-31-83-195:/usr/local/kafka# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic

salutare Bună

Aceasta a fost comanda pe care încerc să o execut în playbook. Dacă aveți exemple care pot duce la un alt prompt, cum ar fi comanda de mai sus (ctrl+c este să iasă din prompt). Vă rog să-mi spuneți cum le putem folosi în manual. Mulțumesc anticipat!

Erori:

Eroare: pentru Playbook 1

root@ip-172-31-87-7:~# ansible-playbook Playbook_to_post_message_into_the_topic.yaml

PLAY [Mesaj în subiect] ******************************************** **************************************************** ************************************

SARCINA [posta mesaj] ********************************************* **************************************************** ******************************************
fatal: [172.31.83.195]: EȘUT! => {"ansible_facts": {"discovered_interpreter_python": "/usr/bin/python3"}, "schimbat": true, "cmd": "/bin/bash -c \"/usr/local/kafka/bin/ kafka-console-producer.sh --broker-list 54.87.252.89:9092 --topic testTopic\"", "delta": "0:00:30.407263", "end": "2022-02-16 08:32 :24.990783", "msg": "cod de returnare diferit de zero", "rc": 129, "start": "2022-02-16 08:31:54.583520", "stdout": ">[2022-02- 16 08:32:07,214] WARN [Producer clientId=console-producer] Bootstrap broker 54.87.252.89:9092 (id: -1 rack: null) deconectat (org.apache.kafka.clients.NetworkClient)\r\n[20222 -02-16 08:32:24,532] WARN [Producer clientId=console-producer] Bootstrap broker 54.87.252.89:9092 (id: -1 rack: null) deconectat (org.apache.kafka.clients.NetworkClient)", " stdout_lines": [">[2022-02-16 08:32:07,214] WARN [Producer clientId=console-producer] Bootstrap broker 54.87.252.89:9092 (id: -1 rack: null) deconectat (org.apache.kaf .clients.NetworkClient)", „[2022-02-16 08:32:24,532] WARN [Producer clientId=console-producer] Broker Bootstrap 54.87.252.89:9092 (id: -1 rack: null) deconectat (org.apache.kafka.clients.NetworkClient)"]}

JOACĂ RECAPITULARE ************************************************ **************************************************** ************************************************
172.31.83.195: ok=0 schimbat=0 inaccesibil=0 eșuat=1 omis=0 salvat=0 ignorat=0

Eroare: pentru Playbook 2

PLAY [Mesaj în subiect] ******************************************** **************************************************** ************************************

SARCINA [posta mesaj] ********************************************* **************************************************** ******************************************
fatal: [172.31.83.195]: EȘUT! => {"ansible_facts": {"discovered_interpreter_python": "/usr/bin/python3"}, "changed": false, "msg": "Parametri neacceptați pentru modulul (comandă): comandă, răspunsuri Parametrii acceptați includ: _raw_params, _uses_shell, argv, chdir, creates, executable, removes, stdin, stdin_add_newline, strip_empty_ends, warn"}

JOACĂ RECAPITULARE ************************************************ **************************************************** ************************************************
172.31.83.195: ok=0 schimbat=0 inaccesibil=0 eșuat=1 omis=0 salvat=0 ignorat=0