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)