diff --git a/CHANGELOG.md b/CHANGELOG.md
index 0c4e013ef6..6cdf796830 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -20,6 +20,8 @@ Main (unreleased)
 
 - Add `validate` command to alloy that will perform limited validation of alloy configuration files. (@kalleep)
 
+- Add `otelcol.receiver.splunkhec` component to receive events in splunk hec format and forward them to other `otelcol.*` components. (@kalleep)
+
 ### Enhancements
 
 - Add binary version to constants exposed in configuration file syntatx. (@adlots)
diff --git a/docs/sources/reference/compatibility/_index.md b/docs/sources/reference/compatibility/_index.md
index 3a0ac187d2..1e18179022 100644
--- a/docs/sources/reference/compatibility/_index.md
+++ b/docs/sources/reference/compatibility/_index.md
@@ -379,6 +379,7 @@ The following components, grouped by namespace, _consume_ OpenTelemetry `otelcol
 - [otelcol.receiver.otlp](../components/otelcol/otelcol.receiver.otlp)
 - [otelcol.receiver.prometheus](../components/otelcol/otelcol.receiver.prometheus)
 - [otelcol.receiver.solace](../components/otelcol/otelcol.receiver.solace)
+- [otelcol.receiver.splunkhec](../components/otelcol/otelcol.receiver.splunkhec)
 - [otelcol.receiver.syslog](../components/otelcol/otelcol.receiver.syslog)
 - [otelcol.receiver.tcplog](../components/otelcol/otelcol.receiver.tcplog)
 - [otelcol.receiver.vcenter](../components/otelcol/otelcol.receiver.vcenter)
diff --git a/docs/sources/reference/components/otelcol/otelcol.receiver.influxdb.md b/docs/sources/reference/components/otelcol/otelcol.receiver.influxdb.md
index c0e3883273..145a374db1 100644
--- a/docs/sources/reference/components/otelcol/otelcol.receiver.influxdb.md
+++ b/docs/sources/reference/components/otelcol/otelcol.receiver.influxdb.md
@@ -26,13 +26,13 @@ otelcol.receiver.influxdb "influxdb_metrics" {
 
 `otelcol.receiver.influxdb` supports the following arguments:
 
-| Name                     | Type           | Description                                                     | Default                                                    | Required |
-| ------------------------ | -------------- | --------------------------------------------------------------- | ---------------------------------------------------------- | -------- |
-| `endpoint`               | `string`       | `host:port` to listen for traffic on.                           | `"localhost:8086"`                                         | no       |
-| `max_request_body_size`  | `string`       | Maximum request body size the server will allow.                | `20MiB`                                                    | no       |
-| `include_metadata`       | `boolean`      | Propagate incoming connection metadata to downstream consumers. |                                                            | no       |
-| `compression_algorithms` | `list(string)` | A list of compression algorithms the server can accept.         | `["", "gzip", "zstd", "zlib", "snappy", "deflate", "lz4"]` | no       |
-`auth`              | `capsule(otelcol.Handler)` | Handler from an `otelcol.auth` component to use for authenticating requests.     |               | no
+| Name                     | Type                       | Description                                                                  | Default                                                    | Required |
+| ------------------------ | -------------------------- | ---------------------------------------------------------------------------- | ---------------------------------------------------------- | -------- |
+| `auth`                   | `capsule(otelcol.Handler)` | Handler from an `otelcol.auth` component to use for authenticating requests. |                                                            | no       |
+| `compression_algorithms` | `list(string)`             | A list of compression algorithms the server can accept.                      | `["", "gzip", "zstd", "zlib", "snappy", "deflate", "lz4"]` | no       |
+| `endpoint`               | `string`                   | `host:port` to listen for traffic on.                                        | `"localhost:8086"`                                         | no       |
+| `include_metadata`       | `boolean`                  | Propagate incoming connection metadata to downstream consumers.              |                                                            | no       |
+| `max_request_body_size`  | `string`                   | Maximum request body size the server will allow.                             | `20MiB`                                                    | no       |
 
 By default, `otelcol.receiver.influxdb` listens for HTTP connections on `localhost`.
 To expose the HTTP server to other machines on your network, configure `endpoint` with the IP address to listen on, or `0.0.0.0:8086` to listen on all network interfaces.
diff --git a/docs/sources/reference/components/otelcol/otelcol.receiver.splunkhec.md b/docs/sources/reference/components/otelcol/otelcol.receiver.splunkhec.md
new file mode 100644
index 0000000000..3198a23ef4
--- /dev/null
+++ b/docs/sources/reference/components/otelcol/otelcol.receiver.splunkhec.md
@@ -0,0 +1,213 @@
+---
+canonical: https://grafana.com/docs/alloy/latest/reference/components/otelcol/otelcol.receiver.splunkhec/
+description: Learn about otelcol.receiver.splunkhec
+labels:
+  stage: public-preview
+  products:
+    - oss
+title: otelcol.receiver.splunkhec
+---
+
+# `otelcol.receiver.splunkhec`
+
+{{< docs/shared lookup="stability/public_preview.md" source="alloy" version="<ALLOY_VERSION>" >}}
+
+`otelcol.receiver.splunkhec` accepts events in the [Splunk HEC format](https://docs.splunk.com/Documentation/Splunk/8.0.5/Data/FormateventsforHTTPEventCollector) and forwards them to other `otelcol.*` components.
+The receiver accepts data formatted as JSON HEC events under any path or as EOL separated log raw data if sent to the `raw_path` path.
+
+{{< admonition type="note" >}}
+`otelcol.receiver.splunkhec` is a wrapper over the upstream OpenTelemetry Collector `splunkhec` receiver.
+Bug reports or feature requests will be redirected to the upstream repository, if necessary.
+{{< /admonition >}}
+
+You can specify multiple `otelcol.receiver.splunkhec` components by giving them different labels.
+
+## Usage
+
+```alloy
+otelcol.receiver.splunkhec "<LABEL>" {
+  output {
+    metrics = [...]
+    logs    = [...]
+  }
+}
+```
+
+## Arguments
+
+You can use the following arguments with `otelcol.receiver.splunkhec`:
+
+| Name                       | Type                       | Description                                                                                                    | Default                                                    | Required |
+| -------------------------- | -------------------------- | ---------------------------------------------------------------------------------------------------------------| ---------------------------------------------------------- | -------- |
+| `access_token_passthrough` | `boolean`                  | If enabled perserves incomming access token as a attribute `com.splunk.hec.access_token`                       | `false`                                                    | no       |
+| `auth`                     | `capsule(otelcol.Handler)` | Handler from an `otelcol.auth` component to use for authenticating requests.                                   |                                                            | no       |
+| `compression_algorithms`   | `list(string)`             | A list of compression algorithms the server can accept.                                                        | `["", "gzip", "zstd", "zlib", "snappy", "deflate", "lz4"]` | no       |
+| `endpoint`                 | `string`                   | `host:port` to listen for traffic on.                                                                          | `"localhost:8088"`                                         | no       |
+| `health_path`              | `string`                   | The path reporting health checks.                                                                              | `/services/collector/health`                               | no       |
+| `include_metadata`         | `boolean`                  | Propagate incoming connection metadata to downstream consumers.                                                |                                                            | no       |
+| `max_request_body_size`    | `string`                   | Maximum request body size the server will allow.                                                               | `20MiB`                                                    | no       |
+| `raw_path`                 | `string`                   | The path accepting raw HEC events. Only applies when the receiver is used for logs.                            | `/services/collector/raw`                                  | no       |
+| `splitting`                | `string`                   | Defines the splitting strategy used by the receiver when ingesting raw events. Can be set to "line" or "none". | `"line"`                                                   | no       |
+
+
+By default, `otelcol.receiver.splunkhec` listens for HTTP connections on `localhost:8088`.
+To expose the HTTP server to other machines on your network, configure `endpoint` with the IP address to listen on, or `0.0.0.0:8088` to listen on all network interfaces.
+
+If `access_token_passthrough` is enabled it will be preserved as a attribute `com.splunk.hec.access_token`.
+If logs or metrics are exported with `otelcol.exporter.splunkhec` it will check for this attribute and if present forward it with outgoing request.
+
+## Blocks
+
+You can use the following blocks with `otelcol.receiver.splunkhec`:
+
+| Block                                                      | Description                                                                | Required |
+| ---------------------------------------------------------- | -------------------------------------------------------------------------- | -------- |
+| [`output`][output]                                         | Configures where to send received telemetry data.                          | yes      |
+| [`cors`][cors]                                             | Configures CORS for the HTTP server.                                       | no       |
+| [`hec_metadata_to_otel_attrs`][hec_metadata_to_otel_attrs] | Configures OpenTelemetry attributes from HEC metadata.                     | no       |
+| [`debug_metrics`][debug_metrics]                           | Configures the metrics that this component generates to monitor its state. | no       |
+| [`tls`][tls]                                               | Configures TLS for the HTTP server.                                        | no       |
+
+[tls]: #tls
+[cors]: #cors
+[debug_metrics]: #debug_metrics
+[output]: #output
+
+### `tls`
+
+The `tls` block configures TLS settings used for a server.
+If the `tls` block isn't provided, TLS isn't used for connections to the server.
+
+{{< docs/shared lookup="reference/components/otelcol-tls-server-block.md" source="alloy" version="<ALLOY_VERSION>" >}}
+
+### `cors`
+
+The `cors` block configures CORS settings for an HTTP server.
+
+The following arguments are supported:
+
+| Name              | Type           | Description                                              | Default                | Required |
+| ----------------- | -------------- | -------------------------------------------------------- | ---------------------- | -------- |
+| `allowed_headers` | `list(string)` | Accepted headers from CORS requests.                     | `["X-Requested-With"]` | no       |
+| `allowed_origins` | `list(string)` | Allowed values for the `Origin` header.                  |                        | no       |
+| `max_age`         | `number`       | Configures the `Access-Control-Max-Age` response header. |                        | no       |
+
+The `allowed_headers` specifies which headers are acceptable from a CORS request.
+The following headers are always implicitly allowed:
+
+* `Accept`
+* `Accept-Language`
+* `Content-Type`
+* `Content-Language`
+
+If `allowed_headers` includes `"*"`, all headers are permitted.
+
+### `hec_metadata_to_otel_attrs`
+
+The `hec_metadata_to_otel_attrs` block configures OpenTelemetry attributes from HEC metadata.
+
+| Name         | Type     | Description                                                   | Default                 | Required |
+| ------------ | -------- | --------------------------------------------------------------| ----------------------- |--------- |
+| `host`       | `string` | Specifies the mapping of the host field to a attribute.       | `host.name`             | no       |
+| `index`      | `string` | Specifies the mapping of the index field to a attribute.      | `com.splunk.index`      | no       |
+| `source`     | `string` | Specifies the mapping of the source field to a attribute.     | `com.splunk.source`     | no       |
+| `sourcetype` | `string` | Specifies the mapping of the sourcetype field to a attribute. | `com.splunk.sourcetype` | no       |
+
+### `debug_metrics`
+
+{{< docs/shared lookup="reference/components/otelcol-debug-metrics-block.md" source="alloy" version="<ALLOY_VERSION>" >}}
+
+### `output`
+
+<span class="badge docs-labels__stage docs-labels__item">Required</span>
+
+The `output` block configures a set of components to forward resulting telemetry data to.
+
+The following arguments are supported:
+
+| Name      | Type                     | Description                           | Default | Required |
+| --------- |--------------------------|---------------------------------------|---------|--------- |
+| `logs`    | `list(otelcol.Consumer)` | List of consumers to send logs to.    | `[]`    | no       |
+| `metrics` | `list(otelcol.Consumer)` | List of consumers to send metrics to. | `[]`    | no       |
+
+You must specify the `output` block, but all its arguments are optional.
+By default, telemetry data is dropped.
+Configure the `metrics` and `logs` arguments accordingly to send telemetry data to other components.
+
+## Exported fields
+
+`otelcol.receiver.splunkhec` doesn't export any fields.
+
+## Component health
+
+`otelcol.receiver.splunkhec` is only reported as unhealthy if given an invalid configuration.
+
+## Debug information
+
+`otelcol.receiver.splunkhec` doesn't expose any component-specific debug information.
+
+## Example
+
+This example forwards received telemetry through a batch processor before finally sending it to an OTLP-capable endpoint:
+
+```alloy
+otelcol.receiver.splunkhec "default" {
+  output {
+    logs    = [otelcol.processor.batch.default.input]
+    metrics = [otelcol.processor.batch.default.input]
+  }
+}
+
+otelcol.processor.batch "default" {
+  output {
+    metrics = [otelcol.exporter.otlp.default.input]
+    traces  = [otelcol.exporter.otlp.default.input]
+  }
+}
+
+otelcol.exporter.otlp "default" {
+  client {
+    endpoint = sys.env("<OTLP_ENDPOINT>")
+  }
+}
+```
+
+## Enable authentication
+
+You can create a `otelcol.receiver.splunkhec` component that requires authentication for requests. This is useful for limiting who can push data to the server. 
+
+{{< admonition type="note" >}}
+Not all OpenTelemetry Collector authentication plugins support receiver authentication.
+Refer to the [documentation](https://grafana.com/docs/alloy/<ALLOY_VERSION>/reference/components/otelcol/) for each `otelcol.auth.*` component to determine its compatibility.
+{{< /admonition >}} 
+
+```alloy
+otelcol.receiver.splunkhec "default" {
+  output {
+    logs    = [otelcol.processor.batch.default.input]
+    metrics = [otelcol.processor.batch.default.input]
+  }
+  auth = otelcol.auth.basic.creds.handler
+}
+
+otelcol.auth.basic "creds" {
+    username = sys.env("<USERNAME>")
+    password = sys.env("<PASSWORD>")
+}
+```
+
+<!-- START GENERATED COMPATIBLE COMPONENTS -->
+
+## Compatible components
+
+`otelcol.receiver.splunkhec` can accept arguments from the following components:
+
+- Components that export [OpenTelemetry `otelcol.Consumer`](../../../compatibility/#opentelemetry-otelcolconsumer-exporters)
+
+
+{{< admonition type="note" >}}
+Connecting some components may not be sensible or components may require further configuration to make the connection work correctly.
+Refer to the linked documentation for more details.
+{{< /admonition >}}
+
+<!-- END GENERATED COMPATIBLE COMPONENTS -->
diff --git a/go.mod b/go.mod
index dca89a8a25..208c943afc 100644
--- a/go.mod
+++ b/go.mod
@@ -156,6 +156,7 @@ require (
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkareceiver v0.122.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/opencensusreceiver v0.122.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/solacereceiver v0.122.0
+	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/splunkhecreceiver v0.122.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/syslogreceiver v0.122.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/tcplogreceiver v0.122.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/vcenterreceiver v0.122.0
@@ -739,6 +740,7 @@ require (
 	github.com/oapi-codegen/runtime v1.0.0 // indirect
 	github.com/ohler55/ojg v1.20.1 // indirect
 	github.com/oklog/ulid v1.3.1 // indirect
+	github.com/open-telemetry/opentelemetry-collector-contrib/extension/ackextension v0.122.0 // indirect
 	github.com/open-telemetry/opentelemetry-collector-contrib/internal/aws/ecsutil v0.122.0 // indirect
 	github.com/open-telemetry/opentelemetry-collector-contrib/internal/common v0.122.0 // indirect
 	github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal v0.122.0 // indirect
diff --git a/go.sum b/go.sum
index 2d93008c2b..1c5103c1a4 100644
--- a/go.sum
+++ b/go.sum
@@ -2046,6 +2046,8 @@ github.com/open-telemetry/opentelemetry-collector-contrib/exporter/splunkhecexpo
 github.com/open-telemetry/opentelemetry-collector-contrib/exporter/splunkhecexporter v0.122.0/go.mod h1:q4n8s6lPiaexXu4YTwyYnDPNbE8OPAloeJaNo5aAT+g=
 github.com/open-telemetry/opentelemetry-collector-contrib/exporter/syslogexporter v0.122.0 h1:G3v1/S90iCgE6cqvmdriA+6zzZ++PEOHP6Uk2I9F/gY=
 github.com/open-telemetry/opentelemetry-collector-contrib/exporter/syslogexporter v0.122.0/go.mod h1:j2iJlR/sVR1IyNBflyGLwaIzOyx6lx8Nk48cVTWlNnY=
+github.com/open-telemetry/opentelemetry-collector-contrib/extension/ackextension v0.122.0 h1:zKJUibTh/5omRXscGwCLzNJOme50l0y+E6v2Q0uhMAA=
+github.com/open-telemetry/opentelemetry-collector-contrib/extension/ackextension v0.122.0/go.mod h1:OO3viI8mYkkxKKlIk6C/u6cx9StvecB43SeLy1A6B4o=
 github.com/open-telemetry/opentelemetry-collector-contrib/extension/basicauthextension v0.122.0 h1:ewnxhmZGo5ugTVk715kZ8uZniek2hQRV5BzBRVTCLR0=
 github.com/open-telemetry/opentelemetry-collector-contrib/extension/basicauthextension v0.122.0/go.mod h1:en/daynTJv23NQOraTOaKCyEzWcty9AN2Kyd1EWtFWM=
 github.com/open-telemetry/opentelemetry-collector-contrib/extension/bearertokenauthextension v0.122.0 h1:6lgYZ6glozouz5SLENMIHRYClTYNfqhJgRE7j9KfT4s=
@@ -2176,6 +2178,8 @@ github.com/open-telemetry/opentelemetry-collector-contrib/receiver/prometheusrec
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/prometheusreceiver v0.122.0/go.mod h1:6CmMa+n3XNtlKTtLXzb39+ZGVFKsx75pBnuAgef9gow=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/solacereceiver v0.122.0 h1:132lphokin3HwtEPtqLNqjYC04tmhXg9FcrXP1vvFh8=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/solacereceiver v0.122.0/go.mod h1:PHIC2G8WlOyX77+llcOgj5znBLE5kknQsaNl+dLY8OU=
+github.com/open-telemetry/opentelemetry-collector-contrib/receiver/splunkhecreceiver v0.122.0 h1:ng/iPs6FXEoeEbzAyqI1jSV/xa0Ut6lqTEk2yip0xik=
+github.com/open-telemetry/opentelemetry-collector-contrib/receiver/splunkhecreceiver v0.122.0/go.mod h1:opxxAzQS1j6fO+WjpeUFSUrBMtHmqLujY+UCFEwLxBU=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/syslogreceiver v0.122.0 h1:OqIchUstl6I4Z/hqYyDq5GznsEZjStg6Hiy9lkn1GVI=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/syslogreceiver v0.122.0/go.mod h1:tAfzSDDpt1ycyJeXRJseGATsJs+BNky0lNZiz4nBjjU=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/tcplogreceiver v0.122.0 h1:XUBCurUM4iH7CZKnZp/2Q6s28sC9f51hrfKwU1/H4xA=
@@ -3164,8 +3168,6 @@ golang.org/x/net v0.15.0/go.mod h1:idbUs1IY1+zTqbi8yxTbhexhEEk5ur9LInksu6HrEpk=
 golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44=
 golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM=
 golang.org/x/net v0.33.0/go.mod h1:HXLR5J+9DxmrqMwG9qjGCxZ+zKXxBru04zlTvWlWuN4=
-golang.org/x/net v0.37.0 h1:1zLorHbz+LYj7MQlSf1+2tPIIgibq2eL5xkrGk6f+2c=
-golang.org/x/net v0.37.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8=
 golang.org/x/net v0.38.0 h1:vRMAPTMaeGqVhG5QyLJHqNDwecKTomGeqbnfZyKlBI8=
 golang.org/x/net v0.38.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8=
 golang.org/x/oauth2 v0.0.0-20170807180024-9a379c6b3e95/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
diff --git a/internal/component/all/all.go b/internal/component/all/all.go
index 9310082b3d..0ebbfd2bfe 100644
--- a/internal/component/all/all.go
+++ b/internal/component/all/all.go
@@ -110,6 +110,7 @@ import (
 	_ "github.com/grafana/alloy/internal/component/otelcol/receiver/otlp"                    // Import otelcol.receiver.otlp
 	_ "github.com/grafana/alloy/internal/component/otelcol/receiver/prometheus"              // Import otelcol.receiver.prometheus
 	_ "github.com/grafana/alloy/internal/component/otelcol/receiver/solace"                  // Import otelcol.receiver.solace
+	_ "github.com/grafana/alloy/internal/component/otelcol/receiver/splunkhec"               // Import otelcol.receiver.splunkhec
 	_ "github.com/grafana/alloy/internal/component/otelcol/receiver/syslog"                  // Import otelcol.receiver.syslog
 	_ "github.com/grafana/alloy/internal/component/otelcol/receiver/tcplog"                  // Import otelcol.receiver.tcplog
 	_ "github.com/grafana/alloy/internal/component/otelcol/receiver/vcenter"                 // Import otelcol.receiver.vcenter
diff --git a/internal/component/loki/source/gelf/gelf_test.go b/internal/component/loki/source/gelf/gelf_test.go
index 955e1808cb..6bbc8e7898 100644
--- a/internal/component/loki/source/gelf/gelf_test.go
+++ b/internal/component/loki/source/gelf/gelf_test.go
@@ -2,7 +2,6 @@ package gelf
 
 import (
 	"context"
-	"fmt"
 	"net"
 	"strings"
 	"testing"
@@ -10,8 +9,8 @@ import (
 
 	"github.com/grafana/alloy/internal/component"
 	"github.com/grafana/alloy/internal/component/common/loki"
+	"github.com/grafana/alloy/internal/runtime/componenttest"
 	"github.com/grafana/alloy/internal/util"
-	"github.com/phayes/freeport"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/stretchr/testify/require"
 )
@@ -26,7 +25,7 @@ func TestGelf(t *testing.T) {
 	testMsg := `{"version":"1.1","host":"example.org","short_message":"A short message","timestamp":1231231123,"level":5,"_some_extra":"extra"}`
 	ch1 := loki.NewLogsReceiver()
 
-	udpListenerAddr := getFreeAddr(t)
+	udpListenerAddr := componenttest.GetFreeAddr(t)
 	args := Arguments{
 		ListenAddress: udpListenerAddr,
 		Receivers:     []loki.LogsReceiver{ch1},
@@ -52,12 +51,3 @@ func TestGelf(t *testing.T) {
 	}
 	require.True(t, found)
 }
-
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-
-	portNumber, err := freeport.GetFreePort()
-	require.NoError(t, err)
-
-	return fmt.Sprintf("127.0.0.1:%d", portNumber)
-}
diff --git a/internal/component/loki/source/syslog/syslog_test.go b/internal/component/loki/source/syslog/syslog_test.go
index 1557ac45dd..4bc4779162 100644
--- a/internal/component/loki/source/syslog/syslog_test.go
+++ b/internal/component/loki/source/syslog/syslog_test.go
@@ -10,9 +10,9 @@ import (
 	"github.com/grafana/alloy/internal/component"
 	"github.com/grafana/alloy/internal/component/common/loki"
 	alloy_relabel "github.com/grafana/alloy/internal/component/common/relabel"
+	"github.com/grafana/alloy/internal/runtime/componenttest"
 	"github.com/grafana/alloy/internal/util"
 	"github.com/grafana/regexp"
-	"github.com/phayes/freeport"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/common/model"
 	"github.com/stretchr/testify/require"
@@ -27,7 +27,7 @@ func Test(t *testing.T) {
 
 	ch1, ch2 := loki.NewLogsReceiver(), loki.NewLogsReceiver()
 	args := Arguments{}
-	tcpListenerAddr, udpListenerAddr := getFreeAddr(t), getFreeAddr(t)
+	tcpListenerAddr, udpListenerAddr := componenttest.GetFreeAddr(t), componenttest.GetFreeAddr(t)
 
 	l1 := DefaultListenerConfig
 	l1.ListenAddress = tcpListenerAddr
@@ -108,7 +108,7 @@ func TestWithRelabelRules(t *testing.T) {
 
 	ch1 := loki.NewLogsReceiver()
 	args := Arguments{}
-	tcpListenerAddr := getFreeAddr(t)
+	tcpListenerAddr := componenttest.GetFreeAddr(t)
 
 	l := DefaultListenerConfig
 	l.ListenAddress = tcpListenerAddr
@@ -167,15 +167,6 @@ func TestWithRelabelRules(t *testing.T) {
 	}
 }
 
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-
-	portNumber, err := freeport.GetFreePort()
-	require.NoError(t, err)
-
-	return fmt.Sprintf("127.0.0.1:%d", portNumber)
-}
-
 func writeMessageToStream(w io.Writer, msg string, formatter formatFunc) error {
 	_, err := fmt.Fprint(w, formatter(msg))
 	if err != nil {
diff --git a/internal/component/otelcol/extension/jaeger_remote_sampling/jaeger_remote_sampling_test.go b/internal/component/otelcol/extension/jaeger_remote_sampling/jaeger_remote_sampling_test.go
index a4a93c1278..67f69fb38e 100644
--- a/internal/component/otelcol/extension/jaeger_remote_sampling/jaeger_remote_sampling_test.go
+++ b/internal/component/otelcol/extension/jaeger_remote_sampling/jaeger_remote_sampling_test.go
@@ -16,7 +16,6 @@ import (
 	"github.com/grafana/alloy/internal/runtime/componenttest"
 	"github.com/grafana/alloy/internal/util"
 	"github.com/grafana/alloy/syntax"
-	"github.com/phayes/freeport"
 	"github.com/stretchr/testify/require"
 )
 
@@ -45,7 +44,7 @@ func TestFileSource(t *testing.T) {
 	err := os.WriteFile(remoteSamplingConfigFile, []byte(remoteSamplingConfig), 0644)
 	require.NoError(t, err)
 
-	listenAddr := getFreeAddr(t)
+	listenAddr := componenttest.GetFreeAddr(t)
 	cfg := fmt.Sprintf(`
 	    http {
 			endpoint = "%s"
@@ -73,7 +72,7 @@ func TestContentSource(t *testing.T) {
 		}
 	}
 	`
-	listenAddr := getFreeAddr(t)
+	listenAddr := componenttest.GetFreeAddr(t)
 	cfg := fmt.Sprintf(`
 	    http {
 			endpoint = "%s"
@@ -295,12 +294,3 @@ func TestUnmarshalRequiresExactlyOneSource(t *testing.T) {
 		require.EqualError(t, err, tc.expectedError)
 	}
 }
-
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-
-	portNumber, err := freeport.GetFreePort()
-	require.NoError(t, err)
-
-	return fmt.Sprintf("localhost:%d", portNumber)
-}
diff --git a/internal/component/otelcol/receiver/datadog/datadog_test.go b/internal/component/otelcol/receiver/datadog/datadog_test.go
index 8cc27ca584..2dc5b86759 100644
--- a/internal/component/otelcol/receiver/datadog/datadog_test.go
+++ b/internal/component/otelcol/receiver/datadog/datadog_test.go
@@ -11,12 +11,11 @@ import (
 	"github.com/grafana/alloy/internal/util"
 	"github.com/grafana/alloy/syntax"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/datadogreceiver"
-	"github.com/phayes/freeport"
 	"github.com/stretchr/testify/require"
 )
 
 func TestRun(t *testing.T) {
-	httpAddr := getFreeAddr(t)
+	httpAddr := componenttest.GetFreeAddr(t)
 
 	ctx := componenttest.TestContext(t)
 	l := util.TestLogger(t)
@@ -43,7 +42,7 @@ func TestRun(t *testing.T) {
 
 func TestArguments_UnmarshalAlloy(t *testing.T) {
 	t.Run("grpc", func(t *testing.T) {
-		httpAddr := getFreeAddr(t)
+		httpAddr := componenttest.GetFreeAddr(t)
 		in := fmt.Sprintf(`
 		endpoint = "%s"
 		cors {
@@ -77,15 +76,6 @@ func TestArguments_UnmarshalAlloy(t *testing.T) {
 	})
 }
 
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-
-	portNumber, err := freeport.GetFreePort()
-	require.NoError(t, err)
-
-	return fmt.Sprintf("localhost:%d", portNumber)
-}
-
 func TestDebugMetricsConfig(t *testing.T) {
 	tests := []struct {
 		testName string
diff --git a/internal/component/otelcol/receiver/influxdb/influxdb_test.go b/internal/component/otelcol/receiver/influxdb/influxdb_test.go
index eba0512f5b..c41257768a 100644
--- a/internal/component/otelcol/receiver/influxdb/influxdb_test.go
+++ b/internal/component/otelcol/receiver/influxdb/influxdb_test.go
@@ -3,13 +3,13 @@ package influxdb_test
 
 import (
 	"context"
-	"fmt"
 	"testing"
 	"time"
 
 	"github.com/grafana/alloy/internal/component/otelcol"
 	"github.com/grafana/alloy/internal/component/otelcol/internal/fakeconsumer"
 	"github.com/grafana/alloy/internal/component/otelcol/receiver/influxdb"
+	alloycomponenttest "github.com/grafana/alloy/internal/runtime/componenttest"
 	"github.com/grafana/alloy/syntax"
 	influxdb2 "github.com/influxdata/influxdb-client-go/v2"
 	influxdb1 "github.com/influxdata/influxdb1-client/v2"
@@ -38,13 +38,6 @@ func (m *mockConsumer) ConsumeMetrics(_ context.Context, md pmetric.Metrics) err
 	return nil
 }
 
-// Helper function to create a free address for testing
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-	port := 8086 // Use a suitable port for testing
-	return fmt.Sprintf("localhost:%d", port)
-}
-
 // provided channel.
 func makeMetricsOutput(ch chan pmetric.Metrics) *otelcol.ConsumerArguments {
 	metricConsumer := fakeconsumer.Consumer{
@@ -98,7 +91,7 @@ func TestInfluxdbUnmarshal(t *testing.T) {
 
 // TestWriteLineProtocol_Alloy tests the InfluxDB receiver's ability to process metrics
 func TestWriteLineProtocol_Alloy(t *testing.T) {
-	addr := getFreeAddr(t)
+	addr := alloycomponenttest.GetFreeAddr(t)
 	config := &influxdbreceiver.Config{
 		ServerConfig: confighttp.ServerConfig{
 			Endpoint: addr,
@@ -160,7 +153,7 @@ func TestWriteLineProtocol_Alloy(t *testing.T) {
 	})
 }
 func TestReceiverStart(t *testing.T) {
-	addr := getFreeAddr(t)
+	addr := alloycomponenttest.GetFreeAddr(t)
 	metricCh := make(chan pmetric.Metrics)
 	config := influxdb.Arguments{
 		HTTPServer: otelcol.HTTPServerArguments{
@@ -187,7 +180,7 @@ func TestReceiverStart(t *testing.T) {
 	require.NoError(t, nil, "Receiver failed to start")
 }
 func TestReceiverProcessesMetrics(t *testing.T) {
-	addr := getFreeAddr(t)
+	addr := alloycomponenttest.GetFreeAddr(t)
 	nextConsumer := &mockConsumer{}
 
 	config := influxdb.Arguments{
diff --git a/internal/component/otelcol/receiver/jaeger/jaeger_test.go b/internal/component/otelcol/receiver/jaeger/jaeger_test.go
index 504754518c..f9d7ba45ef 100644
--- a/internal/component/otelcol/receiver/jaeger/jaeger_test.go
+++ b/internal/component/otelcol/receiver/jaeger/jaeger_test.go
@@ -10,13 +10,12 @@ import (
 	"github.com/grafana/alloy/internal/runtime/componenttest"
 	"github.com/grafana/alloy/internal/util"
 	"github.com/grafana/alloy/syntax"
-	"github.com/phayes/freeport"
 	"github.com/stretchr/testify/require"
 )
 
 // Test ensures that otelcol.receiver.jaeger can start successfully.
 func Test(t *testing.T) {
-	httpAddr := getFreeAddr(t)
+	httpAddr := componenttest.GetFreeAddr(t)
 
 	ctx := componenttest.TestContext(t)
 	l := util.TestLogger(t)
@@ -123,15 +122,6 @@ func TestArguments_UnmarshalAlloy(t *testing.T) {
 	})
 }
 
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-
-	portNumber, err := freeport.GetFreePort()
-	require.NoError(t, err)
-
-	return fmt.Sprintf("localhost:%d", portNumber)
-}
-
 func TestDebugMetricsConfig(t *testing.T) {
 	tests := []struct {
 		testName string
diff --git a/internal/component/otelcol/receiver/opencensus/opencensus_test.go b/internal/component/otelcol/receiver/opencensus/opencensus_test.go
index dff42bbddb..91ad79ecb5 100644
--- a/internal/component/otelcol/receiver/opencensus/opencensus_test.go
+++ b/internal/component/otelcol/receiver/opencensus/opencensus_test.go
@@ -11,14 +11,13 @@ import (
 	"github.com/grafana/alloy/internal/util"
 	"github.com/grafana/alloy/syntax"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/opencensusreceiver"
-	"github.com/phayes/freeport"
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/collector/config/confignet"
 )
 
 // Test ensures that otelcol.receiver.opencensus can start successfully.
 func Test(t *testing.T) {
-	httpAddr := getFreeAddr(t)
+	httpAddr := componenttest.GetFreeAddr(t)
 
 	ctx := componenttest.TestContext(t)
 	l := util.TestLogger(t)
@@ -72,7 +71,7 @@ func TestDefaultArguments_UnmarshalAlloy(t *testing.T) {
 }
 
 func TestArguments_UnmarshalAlloy(t *testing.T) {
-	httpAddr := getFreeAddr(t)
+	httpAddr := componenttest.GetFreeAddr(t)
 	in := fmt.Sprintf(`
 		cors_allowed_origins = ["https://*.test.com", "https://test.com"]
 
@@ -101,15 +100,6 @@ func TestArguments_UnmarshalAlloy(t *testing.T) {
 	require.Equal(t, otelArgs.CorsOrigins[1], "https://test.com")
 }
 
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-
-	portNumber, err := freeport.GetFreePort()
-	require.NoError(t, err)
-
-	return fmt.Sprintf("localhost:%d", portNumber)
-}
-
 func TestDebugMetricsConfig(t *testing.T) {
 	tests := []struct {
 		testName string
diff --git a/internal/component/otelcol/receiver/otlp/otlp_test.go b/internal/component/otelcol/receiver/otlp/otlp_test.go
index 66a93c8f0a..2ddcc96328 100644
--- a/internal/component/otelcol/receiver/otlp/otlp_test.go
+++ b/internal/component/otelcol/receiver/otlp/otlp_test.go
@@ -17,7 +17,6 @@ import (
 	"github.com/grafana/alloy/internal/util"
 	"github.com/grafana/alloy/syntax"
 	"github.com/grafana/dskit/backoff"
-	"github.com/phayes/freeport"
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/collector/config/configgrpc"
 	"go.opentelemetry.io/collector/config/confighttp"
@@ -30,7 +29,7 @@ import (
 // Test performs a basic integration test which runs the otelcol.receiver.otlp
 // component and ensures that it can receive and forward data.
 func Test(t *testing.T) {
-	httpAddr := getFreeAddr(t)
+	httpAddr := componenttest.GetFreeAddr(t)
 
 	ctx := componenttest.TestContext(t)
 	l := util.TestLogger(t)
@@ -119,15 +118,6 @@ func makeTracesOutput(ch chan ptrace.Traces) *otelcol.ConsumerArguments {
 	}
 }
 
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-
-	portNumber, err := freeport.GetFreePort()
-	require.NoError(t, err)
-
-	return fmt.Sprintf("localhost:%d", portNumber)
-}
-
 func TestUnmarshalDefault(t *testing.T) {
 	alloyCfg := `
 		http {}
diff --git a/internal/component/otelcol/receiver/splunkhec/splunkhec.go b/internal/component/otelcol/receiver/splunkhec/splunkhec.go
new file mode 100644
index 0000000000..d379dc57ba
--- /dev/null
+++ b/internal/component/otelcol/receiver/splunkhec/splunkhec.go
@@ -0,0 +1,176 @@
+package splunkhec
+
+import (
+	"fmt"
+
+	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/splunkhecreceiver"
+	otelcomponent "go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/pipeline"
+
+	"slices"
+
+	"github.com/grafana/alloy/internal/component"
+	"github.com/grafana/alloy/internal/component/otelcol"
+	otelconfig "github.com/grafana/alloy/internal/component/otelcol/config"
+	"github.com/grafana/alloy/internal/component/otelcol/receiver"
+	"github.com/grafana/alloy/internal/featuregate"
+)
+
+func init() {
+	component.Register(component.Registration{
+		Name:      "otelcol.receiver.splunkhec",
+		Stability: featuregate.StabilityPublicPreview,
+		Args:      Arguments{},
+
+		Build: func(opts component.Options, args component.Arguments) (component.Component, error) {
+			f := splunkhecreceiver.NewFactory()
+			return receiver.New(opts, f, args.(Arguments))
+		},
+	})
+}
+
+type SplittingStrategy string
+
+const (
+	SplittingStrategyNone SplittingStrategy = "none"
+	SplittingStrategyLine SplittingStrategy = "line"
+)
+
+// MarshalText implements encoding.TextMarshaler
+func (s SplittingStrategy) MarshalText() (text []byte, err error) {
+	return []byte(s), nil
+}
+
+// UnmarshalText implements encoding.TextUnmarshaler
+func (s *SplittingStrategy) UnmarshalText(text []byte) error {
+	str := string(text)
+	switch str {
+	case "none":
+		*s = SplittingStrategyNone
+	case "line":
+		*s = SplittingStrategyLine
+	default:
+		return fmt.Errorf("unknown splitting strategy: %s", str)
+	}
+
+	return nil
+}
+
+type Arguments struct {
+	HTTPServer otelcol.HTTPServerArguments `alloy:",squash"`
+
+	// RawPath for raw data collection. Optional.
+	RawPath string `alloy:"raw_path,attr,optional"`
+
+	// HealthPath for health API. Optional.
+	HealthPath string `alloy:"health_path,attr,optional"`
+
+	// Splitting strategy used, can be either "line" or "none". Optional.
+	Splitting SplittingStrategy `alloy:"splitting,attr,optional"`
+
+	// AccessTokenPassthrough if enabled perserves incomming access token as a attribute "com.splunk.hec.access_token".
+	// `otelcol.exporter.splunkhec` will check for this attribute and if present forward it.
+	AccessTokenPassthrough bool `alloy:"access_token_passthrough,attr,optional"`
+
+	// HecToOtelAttrs creates a mapping from HEC metadata to attributes. Optional.
+	HecToOtelAttrs HecToOtelAttrsArguments `alloy:"hec_metadata_to_otel_attrs,block,optional"`
+
+	// DebugMetrics configures component internal metrics. Optional.
+	DebugMetrics otelconfig.DebugMetricsArguments `alloy:"debug_metrics,block,optional"`
+
+	// Output configures where to send received data. Required.
+	Output *ConsumerArguments `alloy:"output,block"`
+}
+
+type ConsumerArguments struct {
+	Metrics []otelcol.Consumer `alloy:"metrics,attr,optional"`
+	Logs    []otelcol.Consumer `alloy:"logs,attr,optional"`
+}
+
+// HecToOtelAttrsArguments defines the mapping of Splunk HEC metadata to attributes.
+type HecToOtelAttrsArguments struct {
+	// Source indicates the mapping of the source field to a specific unified model attribute. Optional.
+	Source string `alloy:"source,attr,optional"`
+	// SourceType indicates the mapping of the sourcetype field to a specific unified model attribute. Optional.
+	SourceType string `alloy:"sourcetype,attr,optional"`
+	// Index indicates the mapping of the index field to a specific unified model attribute. Optional.
+	Index string `alloy:"index,attr,optional"`
+	// Host indicates the mapping of the host field to a specific unified model attribute. Optional.
+	Host string `alloy:"host,attr,optional"`
+}
+
+// SetToDefault implements syntax.Defaulter.
+func (a *HecToOtelAttrsArguments) SetToDefault() {
+	*a = HecToOtelAttrsArguments{
+		Source:     "com.splunk.source",
+		SourceType: "com.splunk.sourcetype",
+		Index:      "com.splunk.index",
+		Host:       "host.name",
+	}
+}
+
+// SetToDefault implements syntax.Defaulter.
+func (a *Arguments) SetToDefault() {
+	*a = Arguments{
+		HTTPServer: otelcol.HTTPServerArguments{
+			// Default value https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/4b29766cfde3a0eea46439707167084bfc48bad1/receiver/splunkhecreceiver/README.md#L28
+			Endpoint:              "localhost:8088",
+			CompressionAlgorithms: slices.Clone(otelcol.DefaultCompressionAlgorithms),
+		},
+		// Default value https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/9db5375e6a1092e3e93cd4743f257d30735be22c/internal/splunk/common.go#L32
+		RawPath: "/services/collector/raw",
+		// Default value https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/4b29766cfde3a0eea46439707167084bfc48bad1/receiver/splunkhecreceiver/config.go#L32
+		HealthPath: "/services/collector/health",
+		Splitting:  SplittingStrategyLine,
+	}
+	a.HecToOtelAttrs.SetToDefault()
+	a.DebugMetrics.SetToDefault()
+}
+
+// Convert implements receiver.Arguments.
+func (a Arguments) Convert() (otelcomponent.Config, error) {
+	httpServerConfig, err := a.HTTPServer.Convert()
+	if err != nil {
+		return nil, err
+	}
+
+	c := &splunkhecreceiver.Config{
+		ServerConfig: *httpServerConfig,
+		RawPath:      a.RawPath,
+		HealthPath:   a.HealthPath,
+		Splitting:    splunkhecreceiver.SplittingStrategy(a.Splitting),
+	}
+
+	c.AccessTokenPassthroughConfig.AccessTokenPassthrough = a.AccessTokenPassthrough
+	c.HecToOtelAttrs.Source = a.HecToOtelAttrs.Source
+	c.HecToOtelAttrs.SourceType = a.HecToOtelAttrs.SourceType
+	c.HecToOtelAttrs.Index = a.HecToOtelAttrs.Index
+	c.HecToOtelAttrs.Host = a.HecToOtelAttrs.Host
+
+	return c, nil
+}
+
+// DebugMetricsConfig implements receiver.Arguments.
+func (a Arguments) DebugMetricsConfig() otelconfig.DebugMetricsArguments {
+	return a.DebugMetrics
+}
+
+// Exporters implements receiver.Arguments.
+func (a Arguments) Exporters() map[pipeline.Signal]map[otelcomponent.ID]otelcomponent.Component {
+	return nil
+}
+
+// Extensions implements receiver.Arguments.
+func (a Arguments) Extensions() map[otelcomponent.ID]otelcomponent.Component {
+	// FIXME(kalleep): Add support for ack extension.
+	// https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/v0.122.0/extension/ackextension
+	return nil
+}
+
+// NextConsumers implements receiver.Arguments.
+func (a Arguments) NextConsumers() *otelcol.ConsumerArguments {
+	return &otelcol.ConsumerArguments{
+		Metrics: a.Output.Metrics,
+		Logs:    a.Output.Logs,
+	}
+}
diff --git a/internal/component/otelcol/receiver/splunkhec/splunkhec_test.go b/internal/component/otelcol/receiver/splunkhec/splunkhec_test.go
new file mode 100644
index 0000000000..5e53ae5e04
--- /dev/null
+++ b/internal/component/otelcol/receiver/splunkhec/splunkhec_test.go
@@ -0,0 +1,208 @@
+package splunkhec
+
+import (
+	"bytes"
+	"context"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"net/http"
+	"slices"
+	"testing"
+	"time"
+
+	"github.com/oklog/run"
+	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/splunkhecreceiver"
+	"github.com/stretchr/testify/require"
+	"go.opentelemetry.io/collector/config/confighttp"
+	"go.opentelemetry.io/collector/pdata/plog"
+	"go.opentelemetry.io/collector/pdata/pmetric"
+
+	"github.com/grafana/alloy/internal/component/otelcol"
+	"github.com/grafana/alloy/internal/component/otelcol/internal/fakeconsumer"
+	"github.com/grafana/alloy/internal/runtime/componenttest"
+	"github.com/grafana/alloy/internal/util"
+	"github.com/grafana/alloy/syntax"
+)
+
+type HecEvent struct {
+	// type of event: set to "metric" or nil if the event represents a metric, or is the payload of the event.
+	Event any `json:"event"`
+	// dimensions and metric data
+	Fields map[string]any `json:"fields,omitempty"`
+	// hostname
+	Host string `json:"host"`
+	// optional description of the source of the event; typically the app's name
+	Source string `json:"source,omitempty"`
+	// optional name of a Splunk parsing configuration; this is usually inferred by Splunk
+	SourceType string `json:"sourcetype,omitempty"`
+	// optional name of the Splunk index to store the event in; not required if the token has a default index set in Splunk
+	Index string `json:"index,omitempty"`
+	// optional epoch time - set to zero if the event timestamp is missing or unknown (will be added at indexing time)
+	Time float64 `json:"time,omitempty"`
+}
+
+// Test performs a basic integration test which runs the otelcol.receiver.splunkhec
+// component and ensures that it can receive and forward data.
+func Test(t *testing.T) {
+	httpAddr := componenttest.GetFreeAddr(t)
+
+	ctx := componenttest.TestContext(t)
+	l := util.TestLogger(t)
+
+	ctrl, err := componenttest.NewControllerFromID(l, "otelcol.receiver.splunkhec")
+	require.NoError(t, err)
+
+	cfg := fmt.Sprintf(`
+		endpoint = "%s"
+
+		output {
+			// no-op: will be overridden by test code.
+		}
+	`, httpAddr)
+	require.NoError(t, err)
+
+	var args Arguments
+	require.NoError(t, syntax.Unmarshal([]byte(cfg), &args))
+
+	var (
+		logsCh    = make(chan plog.Logs, 1)
+		metricsCh = make(chan pmetric.Metrics, 1)
+	)
+
+	c := &fakeconsumer.Consumer{
+		ConsumeMetricsFunc: func(ctx context.Context, m pmetric.Metrics) error {
+			select {
+			case <-ctx.Done():
+				return ctx.Err()
+			case metricsCh <- m:
+				return nil
+			}
+		},
+		ConsumeLogsFunc: func(ctx context.Context, l plog.Logs) error {
+			select {
+			case <-ctx.Done():
+				return ctx.Err()
+			case logsCh <- l:
+				return nil
+			}
+		},
+	}
+
+	args.Output = &ConsumerArguments{
+		Metrics: []otelcol.Consumer{c},
+		Logs:    []otelcol.Consumer{c},
+	}
+
+	go func() {
+		err := ctrl.Run(ctx, args)
+		require.NoError(t, err)
+	}()
+
+	require.NoError(t, ctrl.WaitRunning(time.Second))
+
+	url := fmt.Sprintf("http://%s", httpAddr)
+
+	// send log event
+	go func() {
+		util.Eventually(t, func(t require.TestingT) {
+			event := HecEvent{
+				Event: map[string]string{
+					"msg":      "some message",
+					"severity": "Info",
+				},
+				Host:       "my_host",
+				Source:     "my_source",
+				SourceType: "my_source_type",
+				Index:      "index",
+				Time:       float64(time.Now().Unix()),
+			}
+
+			buf := bytes.NewBuffer([]byte{})
+			require.NoError(t, json.NewEncoder(buf).Encode(&event))
+
+			_, err := http.DefaultClient.Post(url, "application/json", buf)
+			require.NoError(t, err)
+		})
+	}()
+
+	go func() {
+		// send metric event
+		util.Eventually(t, func(t require.TestingT) {
+			event := HecEvent{
+				Event:      "metric",
+				Host:       "my_host",
+				Source:     "my_source",
+				SourceType: "my_source_type",
+				Index:      "index",
+				Time:       float64(time.Now().Unix()),
+				Fields: map[string]any{
+					"metric_name:name": 1,
+				},
+			}
+
+			buf := bytes.NewBuffer([]byte{})
+			require.NoError(t, json.NewEncoder(buf).Encode(&event))
+			_, err = http.DefaultClient.Post(url, "application/json", buf)
+			require.NoError(t, err)
+		})
+	}()
+
+	resg := &run.Group{}
+	// Wait for our client to get log.
+	resg.Add(func() error {
+		select {
+		case l := <-logsCh:
+			if l.LogRecordCount() != 1 {
+				return errors.New("expected log count 1")
+			}
+			return nil
+		case <-time.After(time.Second):
+			return errors.New("failed waiting for logs")
+		}
+	}, func(_ error) {})
+
+	// Wait for our client to get metric.
+	resg.Add(func() error {
+		select {
+		case m := <-metricsCh:
+			if m.MetricCount() != 1 {
+				return errors.New("expected metric count 1")
+			}
+			return nil
+		case <-time.After(time.Second):
+			return errors.New("failed waiting for metrics")
+		}
+	}, func(_ error) {})
+
+	require.NoError(t, resg.Run())
+}
+
+func TestUnmarshalDefault(t *testing.T) {
+	alloyCfg := `
+	 	output {}
+	`
+	var args Arguments
+	err := syntax.Unmarshal([]byte(alloyCfg), &args)
+	require.NoError(t, err)
+
+	actual, err := args.Convert()
+	require.NoError(t, err)
+
+	expected := splunkhecreceiver.Config{
+		ServerConfig: confighttp.ServerConfig{
+			Endpoint:              "localhost:8088",
+			CompressionAlgorithms: slices.Clone(otelcol.DefaultCompressionAlgorithms),
+		},
+		RawPath: "/services/collector/raw",
+		HealthPath: "/services/collector/health",
+		Splitting:  splunkhecreceiver.SplittingStrategy(SplittingStrategyLine),
+	}
+
+	expected.HecToOtelAttrs.Source = "com.splunk.source"
+	expected.HecToOtelAttrs.SourceType = "com.splunk.sourcetype"
+	expected.HecToOtelAttrs.Index = "com.splunk.index"
+	expected.HecToOtelAttrs.Host = "host.name"
+
+	require.Equal(t, &expected, actual)
+}
diff --git a/internal/component/otelcol/receiver/syslog/syslog_test.go b/internal/component/otelcol/receiver/syslog/syslog_test.go
index 2480095b4a..cf63bdda4e 100644
--- a/internal/component/otelcol/receiver/syslog/syslog_test.go
+++ b/internal/component/otelcol/receiver/syslog/syslog_test.go
@@ -15,7 +15,6 @@ import (
 	"github.com/grafana/alloy/internal/util"
 	"github.com/grafana/alloy/syntax"
 	"github.com/grafana/dskit/backoff"
-	"github.com/phayes/freeport"
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/collector/pdata/plog"
 )
@@ -23,7 +22,7 @@ import (
 // Test performs a basic integration test which runs the otelcol.receiver.syslog
 // component and ensures that it can receive and forward data.
 func Test(t *testing.T) {
-	tcp := getFreeAddr(t)
+	tcp := componenttest.GetFreeAddr(t)
 
 	ctx := componenttest.TestContext(t)
 	l := util.TestLogger(t)
@@ -117,15 +116,6 @@ func makeLogsOutput(ch chan plog.Logs) *otelcol.ConsumerArguments {
 	}
 }
 
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-
-	portNumber, err := freeport.GetFreePort()
-	require.NoError(t, err)
-
-	return fmt.Sprintf("127.0.0.1:%d", portNumber)
-}
-
 func TestUnmarshal(t *testing.T) {
 	alloyCfg := `
 		protocol = "rfc5424"
diff --git a/internal/component/otelcol/receiver/tcplog/tcplog_test.go b/internal/component/otelcol/receiver/tcplog/tcplog_test.go
index c69c21b459..1da7ada72c 100644
--- a/internal/component/otelcol/receiver/tcplog/tcplog_test.go
+++ b/internal/component/otelcol/receiver/tcplog/tcplog_test.go
@@ -15,7 +15,6 @@ import (
 	"github.com/grafana/alloy/internal/util"
 	"github.com/grafana/alloy/syntax"
 	"github.com/grafana/dskit/backoff"
-	"github.com/phayes/freeport"
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/collector/pdata/plog"
 )
@@ -23,7 +22,7 @@ import (
 // Test performs a basic integration test which runs the otelcol.receiver.tcplog
 // component and ensures that it can receive and forward data.
 func Test(t *testing.T) {
-	addr := getFreeAddr(t)
+	addr := componenttest.GetFreeAddr(t)
 
 	ctx := componenttest.TestContext(t)
 	l := util.TestLogger(t)
@@ -109,15 +108,6 @@ func makeLogsOutput(ch chan plog.Logs) *otelcol.ConsumerArguments {
 	}
 }
 
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-
-	portNumber, err := freeport.GetFreePort()
-	require.NoError(t, err)
-
-	return fmt.Sprintf("127.0.0.1:%d", portNumber)
-}
-
 func TestUnmarshal(t *testing.T) {
 	alloyCfg := `
 		listen_address = "localhost:1514"
diff --git a/internal/component/otelcol/receiver/zipkin/zipkin_test.go b/internal/component/otelcol/receiver/zipkin/zipkin_test.go
index 6e8dd72e8f..1d20d6a81a 100644
--- a/internal/component/otelcol/receiver/zipkin/zipkin_test.go
+++ b/internal/component/otelcol/receiver/zipkin/zipkin_test.go
@@ -11,13 +11,12 @@ import (
 	"github.com/grafana/alloy/internal/util"
 	"github.com/grafana/alloy/syntax"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/zipkinreceiver"
-	"github.com/phayes/freeport"
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/collector/config/confighttp"
 )
 
 func TestRun(t *testing.T) {
-	httpAddr := getFreeAddr(t)
+	httpAddr := componenttest.GetFreeAddr(t)
 
 	ctx := componenttest.TestContext(t)
 	l := util.TestLogger(t)
@@ -67,7 +66,7 @@ func TestArguments_UnmarshalDefaults(t *testing.T) {
 
 func TestArguments_UnmarshalAlloy(t *testing.T) {
 	t.Run("grpc", func(t *testing.T) {
-		httpAddr := getFreeAddr(t)
+		httpAddr := componenttest.GetFreeAddr(t)
 		in := fmt.Sprintf(`
 		endpoint = "%s"
 		cors {
@@ -101,15 +100,6 @@ func TestArguments_UnmarshalAlloy(t *testing.T) {
 	})
 }
 
-func getFreeAddr(t *testing.T) string {
-	t.Helper()
-
-	portNumber, err := freeport.GetFreePort()
-	require.NoError(t, err)
-
-	return fmt.Sprintf("localhost:%d", portNumber)
-}
-
 func TestDebugMetricsConfig(t *testing.T) {
 	tests := []struct {
 		testName string
diff --git a/internal/converter/internal/otelcolconvert/converter_splunkhecreceiver.go b/internal/converter/internal/otelcolconvert/converter_splunkhecreceiver.go
new file mode 100644
index 0000000000..686a6804b9
--- /dev/null
+++ b/internal/converter/internal/otelcolconvert/converter_splunkhecreceiver.go
@@ -0,0 +1,69 @@
+package otelcolconvert
+
+import (
+	"fmt"
+
+	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/splunkhecreceiver"
+	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/component/componentstatus"
+	"go.opentelemetry.io/collector/pipeline"
+
+	otelconfig "github.com/grafana/alloy/internal/component/otelcol/config"
+	"github.com/grafana/alloy/internal/component/otelcol/receiver/splunkhec"
+	"github.com/grafana/alloy/internal/converter/diag"
+	"github.com/grafana/alloy/internal/converter/internal/common"
+)
+
+func init() {
+	converters = append(converters, splunkhecReceiverConverter{})
+}
+
+type splunkhecReceiverConverter struct{}
+
+func (splunkhecReceiverConverter) Factory() component.Factory {
+	return splunkhecreceiver.NewFactory()
+}
+
+func (splunkhecReceiverConverter) InputComponentName() string {
+	return "otelcol.receiver.splunkhec"
+}
+
+func (splunkhecReceiverConverter) ConvertAndAppend(state *State, id componentstatus.InstanceID, cfg component.Config) diag.Diagnostics {
+	var diags diag.Diagnostics
+
+	block := common.NewBlockWithOverride(
+		[]string{"otelcol", "receiver", "splunkhec"},
+		state.AlloyComponentLabel(),
+		toSplunkhecReceiver(state, id, cfg.(*splunkhecreceiver.Config)),
+	)
+
+	diags.Add(
+		diag.SeverityLevelInfo,
+		fmt.Sprintf("Converted %s into %s", StringifyInstanceID(id), StringifyBlock(block)),
+	)
+
+	state.Body().AppendBlock(block)
+	return diags
+}
+
+func toSplunkhecReceiver(state *State, id componentstatus.InstanceID, cfg *splunkhecreceiver.Config) *splunkhec.Arguments {
+	args := &splunkhec.Arguments{
+		HTTPServer: *toHTTPServerArguments(&cfg.ServerConfig),
+		RawPath:    cfg.RawPath,
+		HealthPath: cfg.HealthPath,
+		Splitting:  splunkhec.SplittingStrategy(cfg.Splitting),
+		HecToOtelAttrs: splunkhec.HecToOtelAttrsArguments{
+			Source:     cfg.HecToOtelAttrs.Source,
+			SourceType: cfg.HecToOtelAttrs.SourceType,
+			Index:      cfg.HecToOtelAttrs.Index,
+			Host:       cfg.HecToOtelAttrs.Host,
+		},
+		DebugMetrics: common.DefaultValue[otelconfig.DebugMetricsArguments](),
+		Output: &splunkhec.ConsumerArguments{
+			Metrics: ToTokenizedConsumers(state.Next(id, pipeline.SignalLogs)),
+			Logs:    ToTokenizedConsumers(state.Next(id, pipeline.SignalMetrics)),
+		},
+	}
+
+	return args
+}
diff --git a/internal/converter/internal/otelcolconvert/testdata/splunkhec.alloy b/internal/converter/internal/otelcolconvert/testdata/splunkhec.alloy
index 7a0b88df85..bf7f8fbe28 100644
--- a/internal/converter/internal/otelcolconvert/testdata/splunkhec.alloy
+++ b/internal/converter/internal/otelcolconvert/testdata/splunkhec.alloy
@@ -1,17 +1,16 @@
-otelcol.receiver.otlp "default" {
-	grpc {
-		endpoint = "localhost:4317"
-	}
+otelcol.receiver.splunkhec "default" {
+	raw_path = "/raw"
 
-	http {
-		endpoint               = "localhost:4318"
-		compression_algorithms = ["zlib"]
+	hec_metadata_to_otel_attrs {
+		source     = "mysource"
+		sourcetype = "mysourcetype"
+		index      = "myindex"
+		host       = "myhost"
 	}
 
 	output {
 		metrics = [otelcol.exporter.splunkhec.default.input]
 		logs    = [otelcol.exporter.splunkhec.default.input]
-		traces  = [otelcol.exporter.splunkhec.default.input]
 	}
 }
 
diff --git a/internal/converter/internal/otelcolconvert/testdata/splunkhec.yaml b/internal/converter/internal/otelcolconvert/testdata/splunkhec.yaml
index 708effd844..e36e4edbf1 100644
--- a/internal/converter/internal/otelcolconvert/testdata/splunkhec.yaml
+++ b/internal/converter/internal/otelcolconvert/testdata/splunkhec.yaml
@@ -1,12 +1,12 @@
-
 receivers:
-  otlp:
-    protocols:
-      grpc:
-      http:
-        compression_algorithms:
-        - "zlib"
-
+  splunk_hec:
+    raw_path: "/raw"
+    hec_metadata_to_otel_attrs:
+      source: "mysource"
+      sourcetype: "mysourcetype"
+      index: "myindex"
+      host: "myhost"
+    
 exporters:
   splunk_hec:
     # Splunk HTTP Event Collector token.
@@ -52,11 +52,8 @@ exporters:
 service:
   pipelines:
     metrics:
-      receivers: [otlp]
-      exporters: [splunk_hec]
-    traces:
-      receivers: [otlp]
+      receivers: [splunk_hec]
       exporters: [splunk_hec]
     logs:
-      receivers: [otlp]
-      exporters: [splunk_hec]
\ No newline at end of file
+      receivers: [splunk_hec]
+      exporters: [splunk_hec]
diff --git a/internal/runtime/componenttest/addr.go b/internal/runtime/componenttest/addr.go
new file mode 100644
index 0000000000..6383ec1070
--- /dev/null
+++ b/internal/runtime/componenttest/addr.go
@@ -0,0 +1,18 @@
+package componenttest
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/phayes/freeport"
+	"github.com/stretchr/testify/require"
+)
+
+func GetFreeAddr(t *testing.T) string {
+	t.Helper()
+
+	portNumber, err := freeport.GetFreePort()
+	require.NoError(t, err)
+
+	return fmt.Sprintf("127.0.0.1:%d", portNumber)
+}