Assert Kafka enviar funcionou
Estou escrevendo um aplicativo com o Spring Boot para escrever no Kafk
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
e depois dentro do meu método:
kafkaTemplate.send(topic, data)
Mas sinto que estou apenas contando com isso para funcionar, como posso saber se isso funcionou? Se for assíncrono, é uma boa prática retornar um código 200 e esperar que funcione? Estou confuso. Se Kafka não estiver disponível, isso não irá falhar? Não devo ser solicitado a capturar uma exceção?