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
-
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 -
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.
-
Mantenha a conexão com a máquina cliente aberta e abra uma segunda conexão separada com esse computador em uma nova janela.
-
Use sua segunda conexão com a máquina cliente para criar um consumidor no console executando o comando a seguir. Substitua
my-endpointpela string do servidor de bootstrap que você salvou após criar o cluster.<path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-servermy-endpoint--consumer.config client.properties --topic msk-serverless-tutorial --from-beginningVocê começará a ver as mensagens inseridas anteriormente quando usou o comando do produtor do console.
-
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