Etapa 5: produzir e consumir dados

Como produzir e consumir mensagens

1. Execute o comando a seguir para iniciar um produtor de console. BootstrapServerStringSubstitua pela cadeia de conexão em texto simples que você obteve em Criar um tópico. Para obter instruções sobre como recuperar essa cadeia de conexão, consulte Obter os corretores de bootstrap para um cluster da Amazon. MSK

   <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list BootstrapServerString --producer.config client.properties --topic MSKTutorialTopic

2. Insira a mensagem que desejar e pressione Enter. Repita esta etapa duas ou três vezes. Toda vez que você inserir uma linha e pressionar Enter, essa linha será enviada para o cluster do Apache Kafka como uma mensagem separada.

3. Mantenha a conexão com a máquina cliente aberta e abra uma segunda conexão separada com esse computador em uma nova janela.

4. No comando a seguir, BootstrapServerString substitua pela cadeia de conexão em texto simples que você salvou anteriormente. Em seguida, para criar um consumidor no console, execute o comando a seguir com sua segunda conexão com a máquina cliente.

   <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server BootstrapServerString --consumer.config client.properties --topic MSKTutorialTopic --from-beginning

   Você começará a ver as mensagens inseridas anteriormente quando usou o comando do produtor do console.

5. Insira mais mensagens na janela do produtor e observe-as aparecerem na janela do consumidor.