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

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.0.0, 1.1.0
• Component/s: connect
• Assignee: Unassigned
• Reporter: Igor Candido
• Created: 19/Apr/18 17:00
• Updated: 19/Apr/18 17:00

Description

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.