[KAFKA-7551] Refactor to create both producer & consumer in Worker

• Type: Task
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 2.2.0
• Component/s: connect
• Assignee: Magesh kumar Nandakumar
• Reporter: Magesh kumar Nandakumar
• Created: 25/Oct/18 16:56
• Updated: 30/Nov/18 07:41
• Resolved: 30/Nov/18 07:41

Description

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.

Issue Links

• links to: GitHub Pull Request #5842