Etapa 5: produzir e consumir dados

Como produzir e consumir mensagens

1. Execute o comando a seguir para iniciar um produtor de console.

   $KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/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. Como essa é uma nova sessão, defina as variáveis de BOOTSTRAP_SERVER ambiente KAFKA_ROOT e novamente. Para obter informações sobre como definir essas variáveis de ambiente, consulteCriação de um tópico na máquina cliente.

4. Execute o comando a seguir com sua segunda cadeia de conexão com a máquina cliente para criar um consumidor de console.

   $KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic --from-beginning

   Você deve começar a ver as mensagens inseridas anteriormente ao usar o comando console producer.

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