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

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

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. my-endpointSubstitua pela string do servidor bootstrap que você salvou depois de 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 você encontrar classpath problemas ao executar esses comandos, certifique-se de executá-los no diretório correto. Além disso, certifique-se de que o JAR do AWS MSK IAM esteja no libs diretório. Como alternativa, você pode executar comandos do Kafka usando o comando Java completo com explícitoclasspath, conforme 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 Sem Servidor