[exporter/kafka] connection initialization failed to Azure event hub

[rafaelrodrigues3092]

Component(s)

exporter/kafka

What happened?

Description

After v0.135.0, the kafka exporter fails to connect to Azure Event Hub using Franz-Go.
I tested the functionality against Azure Event Hub Standard and Premium, both have the same behavior/error.
The same config works with Sarama when disabling the feature gate exporter.kafkaexporter.UseFranzGo with the 0.135.0 agent version.

When running from Windows, I see the message: wsarecv: An existing connection was forcibly closed by the remote host.
From the container image there's an additional message, a little more descriptive of the issue: re-updating metadata due to err: broker closed the connection immediately after a dial, which happens if the client is using TLS when the broker is not expecting it: is TLS misconfigured on the client or the broker?

I have tried few steps such as playing around with the values of tls as well as the protocol version, but I don't seem to be able to find a combination of settings that will make it work with Franz-Go.

A secondary concern is that these connection errors are being logged with the INFO log level. Do you think it would be more beneficial to log connection errors with WARN ?

Any insight is greatly appreciated.
Thank you in advance.

Steps to Reproduce

In a Windows Server machine, push any signal to Azure Event Hub via Kafka Exporter.

Expected Result

Successful connection

Actual Result

Error:

• wsarecv: An existing connection was forcibly closed by the remote host.
• re-updating metadata due to err: broker closed the connection immediately after a dial, which happens if the client is using TLS when the broker is not expecting it: is TLS misconfigured on the client or the broker?

Collector version

v0.135.0

Environment information

Environment

OS: Windows Server 2019/2022

OpenTelemetry Collector configuration

exporters:
  debug:
    verbosity: basic
  kafka:
    auth:
      sasl:
        mechanism: PLAIN
        password: Endpoint=sb://<EVH_NAMESPACE>.servicebus.windows.net/;SharedAccessKeyName=<KEY_NAME>;SharedAccessKey=<KEY>
        username: $$ConnectionString
    brokers: [<EVH_NAMESPACE>.servicebus.windows.net:9093]
    client_id: otel-collector
    logs:
      encoding: otlp_proto
      topic: vm-logs
    metadata:
      full: true
      retry:
        backoff: 250ms
        max: 3
    metrics:
      encoding: otlp_proto
      topic: vm-metrics
    partition_logs_by_resource_attributes: false
    partition_metrics_by_resource_attributes: false
    partition_traces_by_id: true
    producer:
      allow_auto_topic_creation: false
      compression: gzip
      compression_params:
        level: 2
      flush_max_messages: 0
      max_message_bytes: 1000000
      required_acks: 1
    protocol_version: 2.1.0
    resolve_canonical_bootstrap_servers_only: false
    retry_on_failure:
      enabled: true
      initial_interval: 5s
      max_elapsed_time: 5m
      max_interval: 30s
    sending_queue:
      enabled: true
      num_consumers: 10
      queue_size: 100000
    timeout: 30s
    tls:
      insecure: false

receivers:
  hostmetrics:
    collection_interval: 10s
    scrapers:
      cpu:
        metrics:
          system.cpu.frequency:
            enabled: false
          system.cpu.logical.count:
            enabled: true
          system.cpu.physical.count:
            enabled: false
          system.cpu.time:
            enabled: true
          system.cpu.utilization:
            enabled: true
service:
  pipelines:
    metrics:
      exporters:
      - debug
      - kafka
      receivers:
      - hostmetrics
  telemetry:
    logs:
      level: debug

Log output

2025-09-19T12:32:46.314-0400    debug   builders/builders.go:24 Alpha component. May change in the future.      {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "debug", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics"}
2025-09-19T12:32:46.314-0400    debug   builders/builders.go:24 Beta component. May change in the future.       {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics"}
2025-09-19T12:32:46.319-0400    debug   builders/builders.go:24 Beta component. May change in the future.       {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "hostmetrics", "otelcol.component.kind": "receiver", "otelcol.signal": "metrics"}
2025-09-19T12:32:46.319-0400    info    service@v0.135.0/service.go:211 Starting otelcol-contrib...     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "Version": "0.135.0", "NumCPU": 2}
2025-09-19T12:32:46.319-0400    info    extensions/extensions.go:41     Starting extensions...  {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}}
2025-09-19T12:32:46.324-0400    info    service@v0.135.0/service.go:234 Everything is ready. Begin running and processing data. {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}}
2025-09-19T12:32:47.326-0400    info    Metrics {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "debug", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "resource metrics": 1, "metrics": 2, "data points": 9}
2025-09-19T12:32:47.327-0400    info    franz   kzap@v1.1.2/kzap.go:114 immediate metadata update triggered     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "why": "forced load because we are producing to a topic for the first time"}
2025-09-19T12:32:47.328-0400    info    franz   kzap@v1.1.2/kzap.go:114 producing to a new topic for the first time, fetching metadata to learn its partitions  {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "topic": "vm-metrics"}
2025-09-19T12:32:47.328-0400    debug   franz   kzap@v1.1.2/kzap.go:110 opening connection to broker    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:47.415-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection opened to broker     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:47.415-0400    debug   franz   kzap@v1.1.2/kzap.go:110 issuing api versions request    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "version": 4}
2025-09-19T12:32:47.418-0400    debug   franz   kzap@v1.1.2/kzap.go:110 wrote ApiVersions v4    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_written": 42, "write_wait": 0, "time_to_write": 0, "err": null}
2025-09-19T12:32:47.420-0400    debug   franz   kzap@v1.1.2/kzap.go:110 read ApiVersions v4     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.0005274, "time_to_read": 0.0005683, "err": "read tcp 10.26.82.69:57342->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:47.422-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection initialization failed        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0", "err": "read tcp 10.26.82.69:57342->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:47.422-0400    debug   franz   kzap@v1.1.2/kzap.go:110 opening connection to broker    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:47.439-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection opened to broker     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:47.442-0400    debug   franz   kzap@v1.1.2/kzap.go:110 issuing api versions request    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "version": 4}
2025-09-19T12:32:47.451-0400    debug   franz   kzap@v1.1.2/kzap.go:110 wrote ApiVersions v4    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_written": 42, "write_wait": 0, "time_to_write": 0, "err": null}
2025-09-19T12:32:47.451-0400    debug   franz   kzap@v1.1.2/kzap.go:110 read ApiVersions v4     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.0005111, "time_to_read": 0, "err": "read tcp 10.26.82.69:57343->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:47.455-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection initialization failed        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0", "err": "read tcp 10.26.82.69:57343->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:47.455-0400    debug   franz   kzap@v1.1.2/kzap.go:110 retrying request        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "request": "Metadata", "tries": 1, "backoff": 0.222367253, "time_since_start": 0.1268127, "request_error": "read tcp 10.26.82.69:57343->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host.", "response_error": null}
2025-09-19T12:32:47.681-0400    debug   franz   kzap@v1.1.2/kzap.go:110 opening connection to broker    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:47.695-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection opened to broker     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:47.695-0400    debug   franz   kzap@v1.1.2/kzap.go:110 issuing api versions request    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "version": 4}
2025-09-19T12:32:47.696-0400    debug   franz   kzap@v1.1.2/kzap.go:110 wrote ApiVersions v4    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_written": 42, "write_wait": 0, "time_to_write": 0.0005062, "err": null}
2025-09-19T12:32:47.697-0400    debug   franz   kzap@v1.1.2/kzap.go:110 read ApiVersions v4     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.0001381, "time_to_read": 0.0005081, "err": "read tcp 10.26.82.69:57344->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:47.698-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection initialization failed        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0", "err": "read tcp 10.26.82.69:57344->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:47.699-0400    debug   franz   kzap@v1.1.2/kzap.go:110 opening connection to broker    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:47.725-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection opened to broker     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:47.726-0400    debug   franz   kzap@v1.1.2/kzap.go:110 issuing api versions request    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "version": 4}
2025-09-19T12:32:47.728-0400    debug   franz   kzap@v1.1.2/kzap.go:110 wrote ApiVersions v4    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_written": 42, "write_wait": 0, "time_to_write": 0, "err": null}
2025-09-19T12:32:47.731-0400    debug   franz   kzap@v1.1.2/kzap.go:110 read ApiVersions v4     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.0005797, "time_to_read": 0.0005064, "err": "read tcp 10.26.82.69:57345->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:47.731-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection initialization failed        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0", "err": "read tcp 10.26.82.69:57345->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:47.732-0400    debug   franz   kzap@v1.1.2/kzap.go:110 retrying request        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "request": "Metadata", "tries": 2, "backoff": 0.423770826, "time_since_start": 0.4038521, "request_error": "read tcp 10.26.82.69:57345->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host.", "response_error": null}
2025-09-19T12:32:48.158-0400    debug   franz   kzap@v1.1.2/kzap.go:110 opening connection to broker    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:48.174-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection opened to broker     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:48.175-0400    debug   franz   kzap@v1.1.2/kzap.go:110 issuing api versions request    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "version": 4}
2025-09-19T12:32:48.175-0400    debug   franz   kzap@v1.1.2/kzap.go:110 wrote ApiVersions v4    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_written": 42, "write_wait": 0, "time_to_write": 0, "err": null}
2025-09-19T12:32:48.177-0400    debug   franz   kzap@v1.1.2/kzap.go:110 read ApiVersions v4     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.0007926, "time_to_read": 0.0005071, "err": "read tcp 10.26.82.69:57346->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:48.179-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection initialization failed        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0", "err": "read tcp 10.26.82.69:57346->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:48.179-0400    debug   franz   kzap@v1.1.2/kzap.go:110 opening connection to broker    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:48.191-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection opened to broker     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:48.197-0400    debug   franz   kzap@v1.1.2/kzap.go:110 issuing api versions request    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "version": 4}
2025-09-19T12:32:48.197-0400    debug   franz   kzap@v1.1.2/kzap.go:110 wrote ApiVersions v4    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_written": 42, "write_wait": 0, "time_to_write": 0, "err": null}
2025-09-19T12:32:48.200-0400    debug   franz   kzap@v1.1.2/kzap.go:110 read ApiVersions v4     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.0016535, "time_to_read": 0.0005124, "err": "read tcp 10.26.82.69:57347->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:48.202-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection initialization failed        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0", "err": "read tcp 10.26.82.69:57347->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:48.204-0400    debug   franz   kzap@v1.1.2/kzap.go:110 retrying request        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "request": "Metadata", "tries": 3, "backoff": 0.94738365, "time_since_start": 0.8757673, "request_error": "read tcp 10.26.82.69:57347->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host.", "response_error": null}
2025-09-19T12:32:49.157-0400    debug   franz   kzap@v1.1.2/kzap.go:110 opening connection to broker    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:49.171-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection opened to broker     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:49.172-0400    debug   franz   kzap@v1.1.2/kzap.go:110 issuing api versions request    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "version": 4}
2025-09-19T12:32:49.173-0400    debug   franz   kzap@v1.1.2/kzap.go:110 wrote ApiVersions v4    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_written": 42, "write_wait": 0, "time_to_write": 0, "err": null}
2025-09-19T12:32:49.174-0400    debug   franz   kzap@v1.1.2/kzap.go:110 read ApiVersions v4     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.0005408, "time_to_read": 0.0005076, "err": "read tcp 10.26.82.69:57348->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:49.175-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection initialization failed        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0", "err": "read tcp 10.26.82.69:57348->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:49.176-0400    debug   franz   kzap@v1.1.2/kzap.go:110 opening connection to broker    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:49.189-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection opened to broker     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:49.189-0400    debug   franz   kzap@v1.1.2/kzap.go:110 issuing api versions request    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "version": 4}
2025-09-19T12:32:49.190-0400    debug   franz   kzap@v1.1.2/kzap.go:110 wrote ApiVersions v4    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_written": 42, "write_wait": 0, "time_to_write": 0, "err": null}
2025-09-19T12:32:49.191-0400    debug   franz   kzap@v1.1.2/kzap.go:110 read ApiVersions v4     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.000523, "time_to_read": 0.0005059, "err": "read tcp 10.26.82.69:57349->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:49.192-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection initialization failed        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0", "err": "read tcp 10.26.82.69:57349->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:49.194-0400    info    franz   kzap@v1.1.2/kzap.go:114 new topic metadata wait failed, retrying wait  {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "topic": "vm-metrics", "err": "read tcp 10.26.82.69:57349->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:49.465-0400    info    franz   kzap@v1.1.2/kzap.go:114 metadata update triggered       {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "why": "re-updating metadata due to err: read tcp 10.26.82.69:57349->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:54.196-0400    debug   franz   kzap@v1.1.2/kzap.go:110 opening connection to broker    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:54.216-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection opened to broker     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:54.216-0400    debug   franz   kzap@v1.1.2/kzap.go:110 issuing api versions request    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "version": 4}
2025-09-19T12:32:54.216-0400    debug   franz   kzap@v1.1.2/kzap.go:110 wrote ApiVersions v4    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_written": 42, "write_wait": 0, "time_to_write": 0, "err": null}
2025-09-19T12:32:54.217-0400    debug   franz   kzap@v1.1.2/kzap.go:110 read ApiVersions v4     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.0005234, "time_to_read": 0.0005068, "err": "read tcp 10.26.82.69:57355->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:54.219-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection initialization failed        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0", "err": "read tcp 10.26.82.69:57355->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:54.220-0400    debug   franz   kzap@v1.1.2/kzap.go:110 opening connection to broker    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:54.246-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection opened to broker     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0"}
2025-09-19T12:32:54.247-0400    debug   franz   kzap@v1.1.2/kzap.go:110 issuing api versions request    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "version": 4}
2025-09-19T12:32:54.248-0400    debug   franz   kzap@v1.1.2/kzap.go:110 wrote ApiVersions v4    {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_written": 42, "write_wait": 0, "time_to_write": 0, "err": null}
2025-09-19T12:32:54.249-0400    debug   franz   kzap@v1.1.2/kzap.go:110 read ApiVersions v4     {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.0005698, "time_to_read": 0.0005067, "err": "read tcp 10.26.82.69:57356->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:54.251-0400    debug   franz   kzap@v1.1.2/kzap.go:110 connection initialization failed        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "addr": "<EVHNS_URL>.windows.net:9093", "broker": "seed_0", "err": "read tcp 10.26.82.69:57356->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:54.251-0400    debug   franz   kzap@v1.1.2/kzap.go:110 retrying request        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "request": "Metadata", "tries": 1, "backoff": 0.285097554, "time_since_start": 0.0551232, "request_error": "read tcp 10.26.82.69:57356->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host.", "response_error": null}
2025-09-19T12:32:54.576-0400    debug   franz   kzap@v1.1.2/kzap.go:110 retrying request        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "request": "Metadata", "tries": 2, "backoff": 0.451905812, "time_since_start": 0.3793211, "request_error": "read tcp 10.26.82.69:57358->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host.", "response_error": null}
2025-09-19T12:32:55.069-0400    debug   franz   kzap@v1.1.2/kzap.go:110 retrying request        {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "request": "Metadata", "tries": 3, "backoff": 0.944401109, "time_since_start": 0.8728143, "request_error": "read tcp 10.26.82.69:57361->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host.", "response_error": null}
2025-09-19T12:32:56.051-0400    info    franz   kzap@v1.1.2/kzap.go:114 new topic metadata wait failed, retrying wait  {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "topic": "vm-metrics", "err": "read tcp 10.26.82.69:57363->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}
2025-09-19T12:32:56.503-0400    info    franz   kzap@v1.1.2/kzap.go:114 metadata update triggered       {"resource": {"service.instance.id": "ee10d3de-e909-468b-a018-95e9a3b17c8f", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "metrics", "why": "re-updating metadata due to err: read tcp 10.26.82.69:57363->10.36.108.31:9093: wsarecv: An existing connection was forcibly closed by the remote host."}

Additional context

Disabling the feature gate exporter.kafkaexporter.UseFranzGo fixes the problem temporarily by reverting back to sarama.

Tip

_{React with 👍 to help prioritize this issue. Please use comments to provide useful context, avoiding +1 or me too, to help us triage it. Learn more here.}

[github-actions]

Pinging code owners:

• exporter/kafka: @pavolloffay @MovieStoreGuy @axw

See Adding Labels via Comments if you do not have permissions to add labels yourself.

[rafaelrodrigues3092]

I could not fit all the logs in the issue. In addition to the agent logs from Windows above, here are the container logs :

2025-09-19 14:08:38.027 | 2025-09-19T18:08:38.027Z	debug	builders/builders.go:24	Beta component. May change in the future.	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs"}
2025-09-19 14:08:38.027 | 2025-09-19T18:08:38.027Z	debug	builders/builders.go:24	Alpha component. May change in the future.	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "debug", "otelcol.component.kind": "exporter", "otelcol.signal": "logs"}
2025-09-19 14:08:38.027 | 2025-09-19T18:08:38.027Z	debug	builders/builders.go:24	Stable component.	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "otlp", "otelcol.component.kind": "receiver", "otelcol.signal": "logs"}
2025-09-19 14:08:38.027 | 2025-09-19T18:08:38.027Z	debug	otlpreceiver@v0.135.0/otlp.go:58	created signal-agnostic logger	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "otlp", "otelcol.component.kind": "receiver"}
2025-09-19 14:08:38.028 | 2025-09-19T18:08:38.028Z	info	service@v0.135.0/service.go:211	Starting otelcol-contrib...	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "Version": "0.135.0", "NumCPU": 10}
2025-09-19 14:08:38.028 | 2025-09-19T18:08:38.028Z	info	extensions/extensions.go:41	Starting extensions...	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}}
2025-09-19 14:08:38.029 | 2025-09-19T18:08:38.029Z	info	grpc@v1.75.0/server.go:715	[core] [Server #1]Server created	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "grpc_log": true}
2025-09-19 14:08:38.029 | 2025-09-19T18:08:38.029Z	info	otlpreceiver@v0.135.0/otlp.go:121	Starting GRPC server	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "otlp", "otelcol.component.kind": "receiver", "endpoint": "[::]:4317"}
2025-09-19 14:08:38.029 | 2025-09-19T18:08:38.029Z	info	otlpreceiver@v0.135.0/otlp.go:179	Starting HTTP server	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "otlp", "otelcol.component.kind": "receiver", "endpoint": "[::]:4318"}
2025-09-19 14:08:38.029 | 2025-09-19T18:08:38.029Z	info	service@v0.135.0/service.go:234	Everything is ready. Begin running and processing data.	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}}
2025-09-19 14:08:38.029 | 2025-09-19T18:08:38.029Z	info	grpc@v1.75.0/server.go:911	[core] [Server #1 ListenSocket #2]ListenSocket created	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "grpc_log": true}
2025-09-19 14:08:49.162 | 2025-09-19T18:08:49.162Z	info	Logs	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "debug", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "resource logs": 1, "log records": 1}
2025-09-19 14:08:49.162 | 2025-09-19T18:08:49.162Z	info	franz	kzap@v1.1.2/kzap.go:114	producing to a new topic for the first time, fetching metadata to learn its partitions	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "topic": "vm-metrics"}
2025-09-19 14:08:49.162 | 2025-09-19T18:08:49.162Z	info	franz	kzap@v1.1.2/kzap.go:114	immediate metadata update triggered	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "why": "forced load because we are producing to a topic for the first time"}
2025-09-19 14:08:49.162 | 2025-09-19T18:08:49.162Z	debug	franz	kzap@v1.1.2/kzap.go:110	opening connection to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:49.163 | 2025-09-19T18:08:49.163Z	info	transport/http2_server.go:699	[transport] [server-transport 0xc000557d40] Closing: EOF	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "grpc_log": true}
2025-09-19 14:08:49.163 | 2025-09-19T18:08:49.163Z	info	transport/controlbuf.go:592	[transport] [server-transport 0xc000557d40] loopyWriter exiting with error: transport closed by client	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "grpc_log": true}
2025-09-19 14:08:49.172 | 2025-09-19T18:08:49.168Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection opened to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:49.173 | 2025-09-19T18:08:49.168Z	debug	franz	kzap@v1.1.2/kzap.go:110	issuing api versions request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "version": 4}
2025-09-19 14:08:49.173 | 2025-09-19T18:08:49.168Z	debug	franz	kzap@v1.1.2/kzap.go:110	wrote ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_written": 42, "write_wait": 0.000024168, "time_to_write": 0.000040591, "err": null}
2025-09-19 14:08:49.208 | 2025-09-19T18:08:49.208Z	debug	franz	kzap@v1.1.2/kzap.go:110	read ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.000106765, "time_to_read": 0.039627364, "err": "EOF"}
2025-09-19 14:08:49.208 | 2025-09-19T18:08:49.208Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection initialization failed	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0", "err": "EOF"}
2025-09-19 14:08:49.208 | 2025-09-19T18:08:49.208Z	debug	franz	kzap@v1.1.2/kzap.go:110	opening connection to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:49.213 | 2025-09-19T18:08:49.213Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection opened to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:49.213 | 2025-09-19T18:08:49.213Z	debug	franz	kzap@v1.1.2/kzap.go:110	issuing api versions request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "version": 4}
2025-09-19 14:08:49.213 | 2025-09-19T18:08:49.213Z	debug	franz	kzap@v1.1.2/kzap.go:110	wrote ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_written": 42, "write_wait": 0.000022582, "time_to_write": 0.000042594, "err": null}
2025-09-19 14:08:49.253 | 2025-09-19T18:08:49.253Z	debug	franz	kzap@v1.1.2/kzap.go:110	read ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.000068126, "time_to_read": 0.039879005, "err": "EOF"}
2025-09-19 14:08:49.253 | 2025-09-19T18:08:49.253Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection initialization failed	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0", "err": "EOF"}
2025-09-19 14:08:49.253 | 2025-09-19T18:08:49.253Z	debug	franz	kzap@v1.1.2/kzap.go:110	retrying request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "request": "Metadata", "tries": 1, "backoff": 0.273955343, "time_since_start": 0.090922464, "request_error": "EOF", "response_error": null}
2025-09-19 14:08:49.528 | 2025-09-19T18:08:49.528Z	debug	franz	kzap@v1.1.2/kzap.go:110	opening connection to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:49.537 | 2025-09-19T18:08:49.536Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection opened to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:49.537 | 2025-09-19T18:08:49.536Z	debug	franz	kzap@v1.1.2/kzap.go:110	issuing api versions request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "version": 4}
2025-09-19 14:08:49.537 | 2025-09-19T18:08:49.537Z	debug	franz	kzap@v1.1.2/kzap.go:110	wrote ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_written": 42, "write_wait": 0.000054833, "time_to_write": 0.000145544, "err": null}
2025-09-19 14:08:49.620 | 2025-09-19T18:08:49.619Z	debug	franz	kzap@v1.1.2/kzap.go:110	read ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.000144747, "time_to_read": 0.082676735, "err": "EOF"}
2025-09-19 14:08:49.620 | 2025-09-19T18:08:49.619Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection initialization failed	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0", "err": "EOF"}
2025-09-19 14:08:49.620 | 2025-09-19T18:08:49.619Z	debug	franz	kzap@v1.1.2/kzap.go:110	opening connection to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:49.625 | 2025-09-19T18:08:49.624Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection opened to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:49.625 | 2025-09-19T18:08:49.624Z	debug	franz	kzap@v1.1.2/kzap.go:110	issuing api versions request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "version": 4}
2025-09-19 14:08:49.625 | 2025-09-19T18:08:49.625Z	debug	franz	kzap@v1.1.2/kzap.go:110	wrote ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_written": 42, "write_wait": 0.00001991, "time_to_write": 0.000039243, "err": null}
2025-09-19 14:08:49.665 | 2025-09-19T18:08:49.665Z	debug	franz	kzap@v1.1.2/kzap.go:110	read ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.00006503, "time_to_read": 0.039888206, "err": "EOF"}
2025-09-19 14:08:49.665 | 2025-09-19T18:08:49.665Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection initialization failed	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0", "err": "EOF"}
2025-09-19 14:08:49.665 | 2025-09-19T18:08:49.665Z	debug	franz	kzap@v1.1.2/kzap.go:110	retrying request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "request": "Metadata", "tries": 2, "backoff": 0.473552186, "time_since_start": 0.502517019, "request_error": "EOF", "response_error": null}
2025-09-19 14:08:50.140 | 2025-09-19T18:08:50.139Z	debug	franz	kzap@v1.1.2/kzap.go:110	opening connection to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:50.147 | 2025-09-19T18:08:50.147Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection opened to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:50.147 | 2025-09-19T18:08:50.147Z	debug	franz	kzap@v1.1.2/kzap.go:110	issuing api versions request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "version": 4}
2025-09-19 14:08:50.147 | 2025-09-19T18:08:50.147Z	debug	franz	kzap@v1.1.2/kzap.go:110	wrote ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_written": 42, "write_wait": 0.000043924, "time_to_write": 0.000089752, "err": null}
2025-09-19 14:08:50.191 | 2025-09-19T18:08:50.190Z	debug	franz	kzap@v1.1.2/kzap.go:110	read ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.000158376, "time_to_read": 0.042284624, "err": "EOF"}
2025-09-19 14:08:50.191 | 2025-09-19T18:08:50.190Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection initialization failed	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0", "err": "EOF"}
2025-09-19 14:08:50.191 | 2025-09-19T18:08:50.190Z	debug	franz	kzap@v1.1.2/kzap.go:110	opening connection to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:50.196 | 2025-09-19T18:08:50.196Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection opened to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:50.196 | 2025-09-19T18:08:50.196Z	debug	franz	kzap@v1.1.2/kzap.go:110	issuing api versions request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "version": 4}
2025-09-19 14:08:50.197 | 2025-09-19T18:08:50.196Z	debug	franz	kzap@v1.1.2/kzap.go:110	wrote ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_written": 42, "write_wait": 0.000021259, "time_to_write": 0.000039161, "err": null}
2025-09-19 14:08:50.237 | 2025-09-19T18:08:50.237Z	debug	franz	kzap@v1.1.2/kzap.go:110	read ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.000073634, "time_to_read": 0.040476932, "err": "EOF"}
2025-09-19 14:08:50.238 | 2025-09-19T18:08:50.237Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection initialization failed	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0", "err": "EOF"}
2025-09-19 14:08:50.238 | 2025-09-19T18:08:50.237Z	debug	franz	kzap@v1.1.2/kzap.go:110	retrying request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "request": "Metadata", "tries": 3, "backoff": 0.985109408, "time_since_start": 1.075031706, "request_error": "EOF", "response_error": null}
2025-09-19 14:08:51.224 | 2025-09-19T18:08:51.224Z	debug	franz	kzap@v1.1.2/kzap.go:110	opening connection to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:51.233 | 2025-09-19T18:08:51.233Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection opened to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:51.233 | 2025-09-19T18:08:51.233Z	debug	franz	kzap@v1.1.2/kzap.go:110	issuing api versions request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "version": 4}
2025-09-19 14:08:51.233 | 2025-09-19T18:08:51.233Z	debug	franz	kzap@v1.1.2/kzap.go:110	wrote ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_written": 42, "write_wait": 0.000025307, "time_to_write": 0.00006543, "err": null}
2025-09-19 14:08:51.277 | 2025-09-19T18:08:51.276Z	debug	franz	kzap@v1.1.2/kzap.go:110	read ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.000071738, "time_to_read": 0.042954673, "err": "EOF"}
2025-09-19 14:08:51.277 | 2025-09-19T18:08:51.276Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection initialization failed	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0", "err": "EOF"}
2025-09-19 14:08:51.277 | 2025-09-19T18:08:51.276Z	debug	franz	kzap@v1.1.2/kzap.go:110	opening connection to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:51.286 | 2025-09-19T18:08:51.286Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection opened to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:51.286 | 2025-09-19T18:08:51.286Z	debug	franz	kzap@v1.1.2/kzap.go:110	issuing api versions request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "version": 4}
2025-09-19 14:08:51.286 | 2025-09-19T18:08:51.286Z	debug	franz	kzap@v1.1.2/kzap.go:110	wrote ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_written": 42, "write_wait": 0.000037834, "time_to_write": 0.000081385, "err": null}
2025-09-19 14:08:51.329 | 2025-09-19T18:08:51.329Z	debug	franz	kzap@v1.1.2/kzap.go:110	read ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.000102445, "time_to_read": 0.042523491, "err": "EOF"}
2025-09-19 14:08:51.329 | 2025-09-19T18:08:51.329Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection initialization failed	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0", "err": "EOF"}
2025-09-19 14:08:51.329 | 2025-09-19T18:08:51.329Z	info	franz	kzap@v1.1.2/kzap.go:114	new topic metadata wait failed, retrying wait	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "topic": "vm-metrics", "err": "EOF"}
2025-09-19 14:08:51.606 | 2025-09-19T18:08:51.606Z	info	franz	kzap@v1.1.2/kzap.go:114	metadata update triggered	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "why": "re-updating metadata due to err: EOF"}
2025-09-19 14:08:56.330 | 2025-09-19T18:08:56.330Z	debug	franz	kzap@v1.1.2/kzap.go:110	opening connection to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:56.340 | 2025-09-19T18:08:56.339Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection opened to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:56.340 | 2025-09-19T18:08:56.339Z	debug	franz	kzap@v1.1.2/kzap.go:110	issuing api versions request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "version": 4}
2025-09-19 14:08:56.340 | 2025-09-19T18:08:56.339Z	debug	franz	kzap@v1.1.2/kzap.go:110	wrote ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_written": 42, "write_wait": 0.000053675, "time_to_write": 0.000119389, "err": null}
2025-09-19 14:08:56.386 | 2025-09-19T18:08:56.386Z	debug	franz	kzap@v1.1.2/kzap.go:110	read ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.000189358, "time_to_read": 0.046389481, "err": "EOF"}
2025-09-19 14:08:56.386 | 2025-09-19T18:08:56.386Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection initialization failed	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0", "err": "EOF"}
2025-09-19 14:08:56.386 | 2025-09-19T18:08:56.386Z	debug	franz	kzap@v1.1.2/kzap.go:110	opening connection to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:56.391 | 2025-09-19T18:08:56.391Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection opened to broker	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0"}
2025-09-19 14:08:56.391 | 2025-09-19T18:08:56.391Z	debug	franz	kzap@v1.1.2/kzap.go:110	issuing api versions request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "version": 4}
2025-09-19 14:08:56.391 | 2025-09-19T18:08:56.391Z	debug	franz	kzap@v1.1.2/kzap.go:110	wrote ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_written": 42, "write_wait": 0.000043218, "time_to_write": 0.000044411, "err": null}
2025-09-19 14:08:56.432 | 2025-09-19T18:08:56.432Z	debug	franz	kzap@v1.1.2/kzap.go:110	read ApiVersions v4	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "broker": "seed_0", "bytes_read": 0, "read_wait": 0.000075997, "time_to_read": 0.041134974, "err": "EOF"}
2025-09-19 14:08:56.432 | 2025-09-19T18:08:56.432Z	debug	franz	kzap@v1.1.2/kzap.go:110	connection initialization failed	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "addr": "<EVHNS_URL>.servicebus.windows.net:9093", "broker": "seed_0", "err": "EOF"}
2025-09-19 14:08:56.432 | 2025-09-19T18:08:56.432Z	debug	franz	kzap@v1.1.2/kzap.go:110	retrying request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "request": "Metadata", "tries": 1, "backoff": 0.267005296, "time_since_start": 0.102560109, "request_error": "EOF", "response_error": null}
2025-09-19 14:08:56.811 | 2025-09-19T18:08:56.811Z	debug	franz	kzap@v1.1.2/kzap.go:110	retrying request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "request": "Metadata", "tries": 2, "backoff": 0.55487735, "time_since_start": 0.48099861, "request_error": "EOF", "response_error": null}
2025-09-19 14:08:57.488 | 2025-09-19T18:08:57.488Z	debug	franz	kzap@v1.1.2/kzap.go:110	retrying request	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "request": "Metadata", "tries": 3, "backoff": 1.145394408, "time_since_start": 1.158475604, "request_error": "EOF", "response_error": null}
2025-09-19 14:08:58.750 | 2025-09-19T18:08:58.750Z	info	franz	kzap@v1.1.2/kzap.go:114	new topic metadata wait failed, retrying wait	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "topic": "vm-metrics", "err": "EOF"}
2025-09-19 14:08:59.243 | 2025-09-19T18:08:59.243Z	info	franz	kzap@v1.1.2/kzap.go:114	metadata update triggered	{"resource": {"service.instance.id": "1d5ae229-dc9d-4508-a8aa-7707479eb288", "service.name": "otelcol-contrib", "service.version": "0.135.0"}, "otelcol.component.id": "kafka", "otelcol.component.kind": "exporter", "otelcol.signal": "logs", "why": "re-updating metadata due to err: EOF"}```

[paulojmdias]

@rafaelrodrigues3092 thanks for reporting this issue! Regarding TLS, I'm not sure if you're playing with TLS, maybe had not worked due to #42754. Do you have any way to build a version with this PR fix to test it? If not, I can provide a Windows binary for you to check if that TLS config fix can solve your issue.

Regarding log levels, those were set to 'info' by the franz-go library, as you can see here. I'm not sure if we can handle this on the Collector side, but let's wait for any update from the maintainers.

[axw]

I don't think it would be #42754 since tls isn't being nested under auth in the provided config. I'll try to reproduce the issue.

@rafaelrodrigues3092 is this a Premium SKU again, like in #42226?

EDIT: never mind, just saw this was covered in the description.

[axw]

Notes so far:

• I can reproduce the issue with a Windows Server 2022 VM in Azure
• I can not reproduce the issue on Ubuntu Linux 24.04

[axw]

@rafaelrodrigues3092 I'll need to switch focus back away from this, I'm not getting anywhere. Diagnostic settings aren't logging anything at all, so I have no idea why the broker is killing the connection.

If you're able to ask Azure support if they can see anything from their end, that would be much appreciated.

[axw]

I spent a little more time and I think I found an issue in franz-go. I've opened twmb/franz-go#1102

Also, it seems we're totally ignoring the protocol_version config for the franz-go client. If I hardcode the max verson to 3.8.0 it works when using Wine. I'll put up a fix for that, so you'll at least have a workaround other than reverting to Sarama.

[rafaelrodrigues3092]

I spent a little more time and I think I found an issue in franz-go. I've opened twmb/franz-go#1102

Also, it seems we're totally ignoring the protocol_version config for the franz-go client. If I hardcode the max verson to 3.8.0 it works when using Wine. I'll put up a fix for that, so you'll at least have a workaround other than reverting to Sarama.

Thanks @axw for the quick turnaround.
I was coming back to report that after further testing I found that my linux hosts have no problem at all. This seems to be a windows only issue, but you have already narrowed it down.

Thanks again