Magesh kumar Nandakumar created KAFKA-7551: ----------------------------------------------
Summary: Refactor to create both producer & consumer in Worker Key: KAFKA-7551 URL: https://issues.apache.org/jira/browse/KAFKA-7551 Project: Kafka Issue Type: Task Components: KafkaConnect Reporter: Magesh kumar Nandakumar Assignee: Magesh kumar Nandakumar Fix For: 2.2.0 In distributed mode, the producer is created in the Worker and the consumer is created in the WorkerSinkTask. The proposal is to refactor it so that both of them are created in Worker. This will not affect any functionality and is just a refactoring to make the code consistent. -- This message was sent by Atlassian JIRA (v7.6.3#76005)