[jira] [Created] (KAFKA-6808) Creating source Kafka connectors re-using a name of a deleted connector causes the connector to never push messages to kafka

["Igor Candido (JIRA)" <ji...@apache.org>]

Igor Candido created KAFKA-6808:
-----------------------------------

             Summary: Creating source Kafka connectors re-using a name of a deleted connector causes the connector to never push messages to kafka
                 Key: KAFKA-6808
                 URL: https://issues.apache.org/jira/browse/KAFKA-6808
             Project: Kafka
          Issue Type: Bug
          Components: KafkaConnect
    Affects Versions: 1.1.0, 1.0.0
            Reporter: Igor Candido


I tried to deploy a source kafka connector to a kafka connect instance that previously had a connector with a similar definition deployed to but since had been deleted and the newly deployed connector was not erroring but also wasn't pushing messages to kafka.

 

The connector created was this salesforce [https://github.com/jcustenborder/kafka-connect-salesforce]

 

And the definition of the connector is:

{
  "connector.class": "com.github.jcustenborder.kafka.connect.salesforce.SalesforceSourceConnector",
  "salesforce.username": "XXX",
  "tasks.max": "1",
  "salesforce.consumer.key": "XXX",
  "salesforce.push.topic.name": "Leads",
  "salesforce.instance": "https://eu8.salesforce.com",
  "salesforce.password": "XXX",
  "salesforce.password.token": "XXX",
  "salesforce.version": "36",
  "name": "salesforce-lead-source",
  "kafka.topic": "salesforce-lead",
  "salesforce.consumer.secret": "XXX",
  "salesforce.object": "Lead"
}

 

I tried to restart kafka connect instance and that didn't fix the problem.

 

As soon as I changed the name of the connector it started working without any configuration change or environment change.

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)