'Using Spring EL to add optional postfix from properties to consumerGroup in @KafkaListener

I have simple spring boot application with Kafka Consumers that looks like

@KafkaListener(topics="topic", groupId="SOME_CONSTANT") {
....
}

What I am required to do Is to add optional spring boot property (from env variables but that is not important) lets say: myapp.env: TEST

And when that variable is present I should automatically update consumer group to be SOME_CONSTANT-TEST

I am playing with SPEL

@KafkaListener(topics="topic", groupId="#{ '${myApp.env}' == null ? 'SOME_CONSTANT' : 'SOME_CONSTANT' + '-' + '${myApp.env}}'") {
....
}

But that does not seem to work :/ Any Ideas?



Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source