我使用springcloud配置服务器(版本2.1.3)和springcloudstarter总线kafka。我在gitlab上有一个webhook,它为每个push事件调用/monitor端点。这个调用通过kafka刷新客户机上的属性,主题是“springcloudbus”。是否可以更改kafka中主题为“springcloudbus”的消息的序列化/反序列化的某些属性?例如,我想在producer中设置:
configurations.put(jsonserializer.add\ type\ info\ headers,false);
在消费者中:
configurations.put(jsondesializer.use\ type\ info\ headers,false);configurations.put(jsondesializer.value\u default\u type,package\u class\u notification\u dto);
原因是:我会把Kafka的版本从2.2.1降到0.10.2。
如何通过/monitor剪切刷新以修改kafka消息中的header属性(remove)?
有什么建议吗?
暂无答案!
目前还没有任何答案,快来回答吧!