Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-7551

Refactor to create both producer & consumer in Worker

    XMLWordPrintableJSON

    Details

    • Type: Task
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.2.0
    • Component/s: KafkaConnect
    • Labels:
      None

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                mageshn Magesh kumar Nandakumar
                Reporter:
                mageshn Magesh kumar Nandakumar
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: