Type Members

1.  case class BaseCommandsConsumer(kafkaConsumer: com.embedika.verdi.senderlib.kafka.StreamingKafkaConsumer @izumi.distage.model.definition.Id("commands-kafka-consumer"), handlers: Map[CommandName, KafkaMessageHandlerWrapper[_, _]])(implicit ec: scala.concurrent.ExecutionContext @izumi.distage.model.definition.Id("ec-kafka-consumer")) extends LazyLogging with Product with Serializable

   Базовый consumer для команд из Kafka

   Базовый consumer для команд из Kafka

   kafkaConsumer

   Низкоуровневый consumer

   handlers

   Обрабтчики команд из Kafka

   ec

   Контекст асинхронной обработки команд

2.  class EntityEventsConsumer extends LazyLogging
3.  trait KafkaMessageHandler[A, B] extends AnyRef

   Интерфейс обработчика команды из Kafka

   Интерфейс обработчика команды из Kafka

   A

   Тип входного параметра

   B

   Тип результата

4.  trait KafkaMessageHandlerWrapper[A, B] extends AnyRef

   Обертка над обработчиком Kafka команд, которая реализует пред- и пост-обработку полученной Verdi команды.

   Обертка над обработчиком Kafka команд, которая реализует пред- и пост-обработку полученной Verdi команды.

   A

   Тип входного параметра

   B

   Тип результата