根据文档的测试部分，我可以验证特定负载是否已发送到流。如果这是一个pojo消息，最终被转换成json，那么我似乎找不到Assert该json的本机支持。相反，我只能以pojo的形式访问有效负载，并对其执行各种Assert。
目前，我只有一组单独的测试来确保以我期望的方式将特定的pojo类型序列化为json。但是，也许有一个内置的支持来测试整个过程，从调用一个方法到验证最终以kafka结束的json。