[
https://issues.apache.org/jira/browse/KAFKA-7551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16664021#comment-16664021
]
ASF GitHub Bot commented on KAFKA-7551:
---------------------------------------
mageshn opened a new pull request #5842: KAFKA-7551:Refactor to create producer
& consumer in the worker.
URL: https://github.com/apache/kafka/pull/5842
This is minor refactoring that brings in the creation of producer and
consumer to the Worker. Currently, the consumer is created in the
WorkerSinkTask. This should not affect any functionality and it just makes the
code structure easier to understand.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> 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)
