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

Deleting connector does not delete tasks

    Details

    • Steps to Reproduce:
      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]

        Gliffy Diagrams

          Attachments

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: