You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
While working with Spring Boot, Kotlin, Spring Kafka and utilizing Springs Request Reply template
kotlinVersion = '1.2.61'
springBootVersion = '2.0.5.RELEASE'
springCloudVersion = 'Greenwich.BUILD-SNAPSHOT'
gsonVersion = '2.8.5'
commonsValidatorVersion = '1.4.1'
libphonenumberVersion = '5.5'
log4jVersion = '2.11.1'
junitVersion = '4.12'
protobufGradlePluginVersion = '0.8.6'
springKafkaVersion = '2.1.10.RELEASE'
commonsValidatorVersion = '1.4.1'
jacksonModuleKotlinVersion = '2.9.6'
javaVersion='1.8'
I have stumbled upon an issue here is scenario thats easily replicated
Using Spring KafkaRequestReplyTemplate set up a required client call to REQ/REPLY topics
Using Listener to receive required messages on REQ topic and once received send them to REPLY topic via @sendto the value in @sendto is as follows
@KafkaListener(topics = ["${my.input-request-topic}"]) @sendto("${my.output-reply-topic}")
override fun caseRequestListener(myModel: CommandModel): CommandModel {
logger.warn("SUCCESS RECIVED MESSAGE {} ", myModel)
the above property definition in @sendto does not resolve and kept as is ${my.output-reply-topic}.
The only way this works if I use static declarations or change to use Spring EL using #{ and not Kotlin supported ${myVal}... I also tried git issue with custom property resolver that did not work... what works is something like this : @sendto("#{systemProperties['my.output-response-topic'] ?: 'MY.CMD.CREATE.RESPONSE'}")
The text was updated successfully, but these errors were encountered:
🐞 Bug report
Hi,
While working with Spring Boot, Kotlin, Spring Kafka and utilizing Springs Request Reply template
kotlinVersion = '1.2.61'
springBootVersion = '2.0.5.RELEASE'
springCloudVersion = 'Greenwich.BUILD-SNAPSHOT'
gsonVersion = '2.8.5'
commonsValidatorVersion = '1.4.1'
libphonenumberVersion = '5.5'
log4jVersion = '2.11.1'
junitVersion = '4.12'
protobufGradlePluginVersion = '0.8.6'
springKafkaVersion = '2.1.10.RELEASE'
commonsValidatorVersion = '1.4.1'
jacksonModuleKotlinVersion = '2.9.6'
javaVersion='1.8'
I have stumbled upon an issue here is scenario thats easily replicated
Using Spring KafkaRequestReplyTemplate set up a required client call to REQ/REPLY topics
Using Listener to receive required messages on REQ topic and once received send them to REPLY topic via @sendto the value in @sendto is as follows
@KafkaListener(topics = ["${my.input-request-topic}"])
@sendto("${my.output-reply-topic}")
override fun caseRequestListener(myModel: CommandModel): CommandModel {
logger.warn("SUCCESS RECIVED MESSAGE {} ", myModel)
the above property definition in @sendto does not resolve and kept as is ${my.output-reply-topic}.
The only way this works if I use static declarations or change to use Spring EL using #{ and not Kotlin supported ${myVal}... I also tried git issue with custom property resolver that did not work... what works is something like this :
@sendto("#{systemProperties['my.output-response-topic'] ?: 'MY.CMD.CREATE.RESPONSE'}")
The text was updated successfully, but these errors were encountered: