Each message produced from Spring Cloud Stream includes a "target-protocol" header. This header seems to be hard coded per the line of code below.
A few questions:
- Is there some significance of this header? I don't see it documented in the reference guide
- Is there a way for a binder to override that?
This header seems to be hard coded here:
|
String targetProtocol = binder.getClass().getSimpleName().startsWith("Rabbit") ? "amqp" : "kafka"; |
Each message produced from Spring Cloud Stream includes a "target-protocol" header. This header seems to be hard coded per the line of code below.
A few questions:
This header seems to be hard coded here:
spring-cloud-stream/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
Line 458 in 32a8b9e