问题描述
我将Spring Cloud配置服务器（版本2.1.3）与spring-cloud-starter-bus-kafka一起使用。我在gitlab上有一个Webhook，对于每个推送事件，它都调用/ monitor端点。该调用通过Kafka在主题“ springCloudBus”上刷新客户端上的属性。 是否可以为在主题“ springCloudBus”中流动的kafka中的消息更改序列化/反序列化的某些属性？例如，我想在生产者中设置：
configurations.put（JsonSerializer.ADD_TYPE_INFO_HEADERS，false）;
和消费者：
configurations.put（JsonDeserializer.USE_TYPE_INFO_HEADERS，false）; configuration.put（JsonDeserializer.VALUE_DEFAULT_TYPE，PACKAGE_CLASS_NOTIFICATION_DTO）;
原因是：我会将kafka版本从2.2.1降级到0.10.2。
我如何通过/ monitor整理刷新内容，以便修改kafka消息中的标头属性（删除）？
有什么建议吗？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）