You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/11/30 07:42:00 UTC

[jira] [Resolved] (KAFKA-7551) Refactor to create both producer & consumer in Worker

     [ https://issues.apache.org/jira/browse/KAFKA-7551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ewen Cheslack-Postava resolved KAFKA-7551.
------------------------------------------
    Resolution: Fixed

Merged [https://github.com/apache/kafka/pull/5842,] my bad for screwing up closing the Jira along with the fix...

> 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
>            Priority: Minor
>             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)