Docs Connect Components Catalog Inputs otlp_http otlp_http Page options Copy as Markdown Copied! View as plain text Ask AI about this topic Add MCP server to VS Code Type: Input ▼ InputOutput Available in: Self-Managed Receive OpenTelemetry traces, logs, and metrics via OTLP/HTTP protocol. Introduced in version 4.78.0. Exposes an OpenTelemetry Collector HTTP receiver that accepts traces, logs, and metrics via HTTP. Telemetry data is received in OTLP format (both protobuf and JSON) at standard OTLP endpoints and converted to individual Redpanda OTEL v1 protobuf messages. Each signal (span, log record, or metric) becomes a separate message with embedded Resource and Scope metadata, optimized for Kafka partitioning. Common Advanced inputs: label: "" otlp_http: address: 0.0.0.0:4318 rate_limit: "" inputs: label: "" otlp_http: address: 0.0.0.0:4318 tls: enabled: false cert_file: "" key_file: "" auth_token: "" read_timeout: 10s write_timeout: 10s max_body_size: 4194304 rate_limit: "" tcp: reuse_addr: false reuse_port: false Endpoints This input exposes the following standard OTLP HTTP endpoints: /v1/traces - OpenTelemetry traces /v1/logs - OpenTelemetry logs /v1/metrics - OpenTelemetry metrics Protocols This input supports OTLP/HTTP on the default port 4318. It accepts both: application/x-protobuf - OTLP protobuf format application/json - OTLP JSON format Output format Each OTLP export request is unbatched into individual messages: Traces: One message per span Logs: One message per log record Metrics: One message per metric Messages are encoded in Redpanda OTEL v1 protobuf format. Metadata This input adds the following metadata fields to each message: signal_type - The signal type: "trace", "log", or "metric" You can access these metadata fields using function interpolation. Authentication When auth_token is configured, clients must include the token in the HTTP Authorization header. Go client example import ( "go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp" ) exporter, err := otlptracehttp.New(ctx, otlptracehttp.WithEndpoint("localhost:4318"), otlptracehttp.WithInsecure(), // or WithTLSClientConfig() for TLS otlptracehttp.WithHeaders(map[string]string{ "Authorization": "Bearer your-token-here", }), ) cURL example curl -X POST http://localhost:4318/v1/traces \ -H "Content-Type: application/x-protobuf" \ -H "Authorization: Bearer your-token-here" \ --data-binary @traces.pb Environment variable export OTEL_EXPORTER_OTLP_HEADERS="Authorization=Bearer your-token-here" Rate limiting An optional rate limit resource can be specified to throttle incoming requests. When the rate limit is breached, requests will receive a 429 (Too Many Requests) response. Fields address The address to listen on for HTTP connections. Type: string Default: 0.0.0.0:4318 auth_token Optional bearer token for authentication. When set, requests must include 'Authorization: Bearer <token>' header. This field contains sensitive information that usually shouldn’t be added to a configuration directly. For more information, see Secrets. Type: string Default: "" max_body_size Maximum size of HTTP request body in bytes. Type: int Default: 4194304 rate_limit An optional rate limit resource to throttle requests. Type: string Default: "" read_timeout Maximum duration for reading the entire request. Type: string Default: 10s tcp TCP listener socket configuration. Type: object tcp.reuse_addr Enable SO_REUSEADDR, allowing binding to ports in TIME_WAIT state. Useful for graceful restarts and config reloads where the server needs to rebind to the same port immediately after shutdown. Type: bool Default: false tcp.reuse_port Enable SO_REUSEPORT, allowing multiple sockets to bind to the same port for load balancing across multiple processes/threads. Type: bool Default: false tls TLS configuration for HTTP. Type: object tls.cert_file Path to the TLS certificate file. Type: string Default: "" tls.enabled Enable TLS connections. Type: bool Default: false tls.key_file Path to the TLS key file. Type: string Default: "" write_timeout Maximum duration for writing the response. Type: string Default: 10s Back to top × Simple online edits For simple changes, such as fixing a typo, you can edit the content directly on GitHub. Edit on GitHub Or, open an issue to let us know about something that you want us to change. Open an issue Contribution guide For extensive content updates, or if you prefer to work locally, read our contribution guide . Was this helpful? thumb_up thumb_down group Ask in the community mail Share your feedback group_add Make a contribution 🎉 Thanks for your feedback! ockam_kafka otlp_grpc