Class ConsumerExecutorServiceConfig

java.lang.Object
io.micronaut.configuration.kafka.executor.ConsumerExecutorServiceConfig

@Requires(missingProperty="micronaut.executors.consumer") @Factory public class ConsumerExecutorServiceConfig extends Object
Configures a ScheduledExecutorService for running KafkaListener instances.
Since:
1.0
Author:
Graeme Rocher
  • Constructor Details

    • ConsumerExecutorServiceConfig

      public ConsumerExecutorServiceConfig()