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)
