Returns a specification to start this module under a supervisor.

See Supervisor.

Specs

config() :: any()

Returns module configuration.

If application environment contains values in Keyword or Map struct, defaults from macro usage will be recursively merged with application configuration.

If one of the configuration parameters does not exist or can not be resolved, raises ArgumentError.

Specs

kafka_handler(Cloudevents.kafka_body(), Cloudevents.kafka_headers()) ::
  :ok
  | {:error,
     %{
       :__exception__ => true,
       :__struct__ => atom(),
       optional(atom()) => any()
     }, any()}

Specs

validate(any()) :: {:ok, any()}