pizza_bulk

pizza_bulk #

CategoryScope
Sinkrecord

The “pizza_bulk” output processor: ship the processed batch to a Pizza engine (serve mode) via its Elasticsearch-style /_bulk endpoint. Records are taken from the consumer’s message batch (otel envelopes), rendered as NDJSON bulk lines with an index-name template.

Configuration #

FieldTypeDefaultDescription
endpointstringOTLP/gRPC endpoint, e.g. otelcol:4317.
indexstring“logs”Destination index name.
timeoutstring“10s”Overall request timeout.
message_fieldstring“messages”Context key holding the message batch.

Example #

processor:
  - pizza_bulk:
      endpoint: "otelcol:4317"
      index: "index"
      timeout: "30s"
      message_field: "message_field"
Edit Edit this page