当我将有效负载发布到kafka主题时,如果某个特定字段具有空值或空字符串,则该字段根本不会显示在kafka主题的有效负载中。我希望字段仍然显示为null或空字符串值。
例如,如果我发布一个包含两个字段的有效负载,其中一个字段名为 firstname
“和价值” Sara
,以及另一个名为 lastname
值为 null
或者 “”
在Kafka的主题中,只有 firstname
“带值字段” Sara
“,而且没有 lastname
显示所有字段。我想要 lastname
显示值为的字段 null
或者 “”
.
有人能帮我理解为什么会这样吗?我是通过lenses.io查看数据的,所以ui可能只是没有显示空值?在我的java代码中配置kafkaproducer时,是否可能需要设置一些配置,或者是kafka集群上的一些配置导致了这种情况?
1条答案
按热度按时间qhhrdooz1#
供pojo序列化使用
@JsonInclude(Include.ALWAYS)
方法使用objectmapper进行序列化
objectMapper.setSerializationInclusion()
方法