Closed slifty closed 4 years ago
We currently have a Countertop that can accept new appliances and use that set of appliances to generate a stream topology.
The next step is to actually use that topology to create workers and start generating / processing data as per a given appliance configuration.
Using the API defined in #82, enable the start and stop methods for the CountertopCoordinator.
start
stop
CountertopCoordinator
This is going to involve creating the concept of a CountertopWorker and thinking carefully about how to differentiate streams within Kafka.
CountertopWorker
None
Task
Description
We currently have a Countertop that can accept new appliances and use that set of appliances to generate a stream topology.
The next step is to actually use that topology to create workers and start generating / processing data as per a given appliance configuration.
Using the API defined in #82, enable the
startandstopmethods for theCountertopCoordinator.This is going to involve creating the concept of a
CountertopWorkerand thinking carefully about how to differentiate streams within Kafka.Relevant Resources / Research
None
Related Issues
82
23