Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-4521

Connector is still in 'RUNNING' status even though the heartbeat failed.

    • Icon: Bug Bug
    • Resolution: Can't Do
    • Icon: Critical Critical
    • None
    • 1.7.1.Final
    • postgresql-connector
    • None
    • False
    • False
    • Hide

      Prerequisites:

      • Debezium connector with heartbeat configuration ( "heartbeat.topics.prefix" is set)
      • Heartbeat topic on Kafka side does NOT exists
      • Parameter auto.create.topics is disabled (=false)

      Execution:

      • Connector was created
      • Connector starts the heartbeat
      • Connector logs the following entry: [WARN] 2022-01-06 13:25:30,094 [kafka-producer-network-thread | connector-producer-itgermany.pmops.dispoapp.gateway.DE-350.debeziumconnector-0] org.apache.kafka.clients.NetworkClient handleSuccessfulResponse - [Producer clientId=connector-producer-itgermany.pmops.dispoapp.gateway.DE-350.debeziumconnector-0] Error while fetching metadata with correlation id 38409 : {itgermany.pmops.dispoapp.gateway.heartbeat.GatewayDepot35=UNKNOWN_TOPIC_OR_PARTITION}
      • Connector status remains 'RUNNING'
      • NO Data comes to Kafka via the Connector

      Troubleshooting:

      • Re-creating the connector caused data to be sent to Kafka for a short time (until the heartbeat was repeated).

       

      Show
      Prerequisites: Debezium connector with heartbeat configuration ( "heartbeat.topics.prefix" is set) Heartbeat topic on Kafka side does NOT exists Parameter auto.create.topics is disabled (=false) Execution: Connector was created Connector starts the heartbeat Connector logs the following entry: [WARN] 2022-01-06 13:25:30,094 [kafka-producer-network-thread | connector-producer-itgermany.pmops.dispoapp.gateway.DE-350.debeziumconnector-0] org.apache.kafka.clients.NetworkClient handleSuccessfulResponse - [Producer clientId=connector-producer-itgermany.pmops.dispoapp.gateway.DE-350.debeziumconnector-0] Error while fetching metadata with correlation id 38409 : {itgermany.pmops.dispoapp.gateway.heartbeat.GatewayDepot35=UNKNOWN_TOPIC_OR_PARTITION} Connector status remains 'RUNNING' NO Data comes to Kafka via the Connector Troubleshooting: Re-creating the connector caused data to be sent to Kafka for a short time (until the heartbeat was repeated).  

      Heartbeat fails because the heartbeat topic does not exist and the auto.create.topics parameter is set to false, but the status of the connector remains 'Running'.

       

      Our expectations:

      The connector should go to status 'failed' after a few failed heartbeat attempts. At the moment - status = 'running' - everything looks good and we wonder why no data arrives in Kafka.

              Unassigned Unassigned
              andreasgi Andreas Gillmann (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Created:
                Updated:
                Resolved: