Estou tendo uma dificuldade de fazer o detalhamento de recebimento de eventos através do kafkaEmbeded. Minha aplicação é somente consumer e não sei como implementar esse método.
Você está vendo a versão anterior da nova experiência da Alura que estamos preparando para você. Em breve, ela ganha uma identidade visual novinha totalmente pensada em potencializar seus estudos!
Estou tendo uma dificuldade de fazer o detalhamento de recebimento de eventos através do kafkaEmbeded. Minha aplicação é somente consumer e não sei como implementar esse método.
Olá Aline, tudo bem?
Entendo que você está tendo dificuldades em elaborar o producer e consumer do Kafka pelo Cucumber. Para implementar o método de recebimento de eventos através do KafkaEmbedded em sua aplicação consumer, você pode seguir os seguintes passos:
Segue um exemplo de código para o consumer do Kafka:
public class MeuConsumer implements Consumer<String, String> {
@Override
public void consume(ConsumerRecord<String, String> record) {
System.out.println("Recebido evento: " + record.value());
// Implemente a lógica de recebimento do evento aqui
}
@Override
public void close() {
// Implemente a lógica de fechamento do consumer aqui
}
}Espero que essas dicas te ajudem a implementar o método de recebimento de eventos através do KafkaEmbedded em sua aplicação consumer. Caso ainda tenha dúvidas, não hesite em perguntar!
Espero ter ajudado e bons estudos!