Skip to content

Change how ReadTopic/WriteTopic create kafka Consumer/Producer. #41

Description

@tribeiro

The current implementation of ReadTopic and WriteTopic uses Consumer::from_hosts and Producer::from_hosts. These creates individual Clients for each one of them, which ends up duplicating resources and making schema registration more challenging, since a client is required (see #39). This issue is to refactor the code to use from_client instead. The new method should probably receive a client, which can be shared.

I think the client should probably be part of the Domain, which is supposes to host shareable resources.

Metadata

Metadata

Assignees

Labels

enhancementNew feature or requestv0.2Version 0.2

Projects

Status
Todo

Relationships

None yet

Development

No branches or pull requests

Issue actions