Instance Constructors

1.  new EventSource(consumerGroup: String = "", source: Source = kalix.eventing.EventSource.Source.Empty, ignore: Boolean = false, ignoreUnknown: Option[Boolean] = _root_.scala.None, handleDeletes: Option[Boolean] = _root_.scala.None, startFromSnapshots: Option[Boolean] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty)
   consumerGroup

   The consumer group id. By default, all rpc methods on a given service with the same source will be part of the same virtual consumer group, messages will be routed to the different methods by type. This can be used to override that. If you want multiple methods to act as independent consumers of the same source (ie, if you want the same event to be published to each consumer) then give each consumer a unique name. Note that this does depend on the event source supporting multiple consumer groups. Queue based event sources may not support this.

   ignore

   If the message is not of interest for consumption the method for that input message type can be marked with ignore: true. Enabling is more efficient than implementing the method. This option can only be used on method level

   ignoreUnknown

   If an incoming event does not have a matching handler, ignore the event and continue processing subsequent events, default is to fail to not accidentally miss events of newly added or unknown event types, as once eventing has continued there is no way to later revisit the ignored event. Enabling is more efficient than implementing a catch-all method. This option can only be used on service level.

   handleDeletes

   Call this method when an entity has been deleted, the method must accept google.protobuf.Empty as input. If the method is in a view the return type should be the view state message type, for other types of components the returned message type can be an arbitrary message, for example for publishing to eventing out on delete. Currently supported only for the value entity streams.

   startFromSnapshots

   Start consuming from snapshots for event sourced entity sources. When enabled, the consumer will start by processing the latest snapshot state for each entity before processing subsequent events. This can significantly reduce startup time for consumers that need to rebuild state from a long event history. Only applicable for event_sourced_entity sources.