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

Deleting connector does not delete tasks

    XMLWordPrintable

Details

    • Bug
    • Resolution: Cannot Reproduce
    • Minor
    • 0.10.0.Final
    • 0.10.0.Final
    • mysql-connector
    • None
    • Hide

      Create a connector, make sure it is in a RUNNING state
      Delete the connector, dbhistory, and connect-cluster-offset topic

      Show
      Create a connector, make sure it is in a RUNNING state Delete the connector, dbhistory, and connect-cluster-offset topic

    Description

      I tried deleting a debezium mysql connector and I'm noticing that the task associated with it is still in a RUNNING state:

      curl platform-connect-api:8083/connectors/discogs-releases | jq
      {
        "error_code": 404,
        "message": "Connector discogs-releases not found"
      }
      
      curl platform-connect-api:8083/connectors/discogs-releases/tasks/0/status | jq
      {
        "id": 0,
        "state": "RUNNING",
        "worker_id": "10.22.7.178:8083"
      }
      

      There are some details that might be relevant:

      • After deleting the connector, I tried deleting the main topic, the history topic and the connect-offset-topic
      • After all of that I'm now getting a stream of warnings in the connect logs like this:

      2020-01-09 18:51:36,715 WARN [Producer clientId=producer-2] Received invalid metadata error in produce request on partition connect-cluster-status-0 due to org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.. Going to request metadata update now (org.apache.kafka.clients.producer.internals.Sender) [kafka-producer-network-thread | producer-2]

      Attachments

        Activity

          People

            Unassigned Unassigned
            jonslusher Jon Slusher
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: