snippet.java

@Incoming("product-in")
public Uni<Void> processProduct(Message<String> message) {
        final Serde<Product> serde = DebeziumSerdes.payloadJson(Product.class);
        serde.configure(Collections.singletonMap("from.field", "after"), false);
        Product product = serde.deserializer().deserialize("product-in", message.getPayload().getBytes());
        //Do complicated stuff with product
        Log.info(product.getName());
        return Uni.createFrom().nullItem();
    }