RigInboundGateway.ApiProxy.Handler.Kafka (Reactive Interaction Gateway v3.0.0-alpha.2) View Source

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.

do_handle_http_request(conn, request_path, partition, event, response_from, topic \\ nil, schema \\ nil)

handle_http_request(conn, api, endpoint, request_path)

Produce the request to a Kafka topic and optionally wait for the (correlated) response.

Expects a JSON encoded CloudEvent in the HTTP body.

Optionally set a partition key via this field:

rig: {"target_partition":"the-partition-key"}

kafka_handler(message, headers)

Specs

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

respond_with_bad_request(conn, response_from, description)

start_link(opts \\ [])

validate(conf)

Specs

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