Qual o problema de utilizar o Object como interface do KafkaDispatcher
exemplo:
try(var dispatcher = new KafkaDispatcher<Object>()) {
for (int i = 0; i < 100; i++) {
var userId = UUID.randomUUID().toString();
var orderId = UUID.randomUUID().toString();
var amount = Math.random() * 5000 + 1;
var order = new Order(userId,orderId, BigDecimal.valueOf(amount));
var email = "Thank you for your order! We are processing your order!";
dispatcher.send("ECOMMERCE_NEW_ORDER", userId,order);
dispatcher.send("ECOMMERCE_SEND_EMAIL", userId, email);
}
}
é por questão de segurança? pois foi serializado desta forma.