Skip to content

Commit

Permalink
add option to enable\disable specific consumers
Browse files Browse the repository at this point in the history
  • Loading branch information
slamdev committed Dec 14, 2021
1 parent cd9c246 commit 86dc1a9
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ public class {{classname}} {
String {{{vendorExtensions.x-topic-const}}} = "{{{vendorExtensions.x-topic-name}}}";

@KafkaListener(topics = {{{vendorExtensions.x-topic-const}}},
autoStartup = "${spring.kafka.listener.auto-startup:true}",
autoStartup = "${spring.kafka.listener.{{{vendorExtensions.x-topic-name}}}.auto-startup:${spring.kafka.listener.auto-startup:true}}",
properties = {
"spring.json.value.default.type={{package}}.{{>returnTypes}}",
"spring.json.type.mapping=event:{{package}}.{{>returnTypes}}",
Expand Down

0 comments on commit 86dc1a9

Please sign in to comment.