Produzir e consumir dados no MSK Sem Servidor - Amazon Managed Streaming for Apache Kafka

Produzir e consumir dados no MSK Sem Servidor

Nesta etapa, você produz e consome dados usando o tópico que criou na etapa anterior.

Como produzir e consumir mensagens
  1. Execute o comando a seguir para criar um produtor de console.

    <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list $BS --producer.config client.properties --topic msk-serverless-tutorial
  2. Insira a mensagem que desejar e pressione Enter. Repita esta etapa duas ou três vezes. Sempre que você inserir uma linha e pressionar Enter, essa linha será enviada para o cluster 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. Use sua segunda conexão com a máquina cliente para criar um consumidor no console executando o comando a seguir. Substitua my-endpoint pela string do servidor de bootstrap que você salvou após criar o cluster.

    <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server my-endpoint --consumer.config client.properties --topic msk-serverless-tutorial --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.

Se encontrar problemas no classpath enquanto executa esses comandos, verifique se eles estão sendo executados no diretório correto. Também certifique-se de que o JAR do IAM do AWS MSK esteja no diretório libs. Como alternativa, você pode executar comandos do Kafka usando o comando Java completo com classpath explícito, como mostrado no exemplo a seguir.

java -cp "kafka_2.12-2.8.1/libs/*:kafka_2.12-2.8.1/libs/aws-msk-iam-auth-2.3.0-all.jar" org.apache.kafka.tools.ConsoleProducer —broker-list $BS —producer.config client.properties —topic msk-serverless-tutorial

Próxima etapa

Excluir recursos que você criou para o MSK Serverless