Closed ThisIsMissEm closed 5 months ago
This also changes the internal APIs a little bit to be clearer:
kafka.start
kafka.boot
startConsumerGroups
startProducers
kafka.disconnect
kafka.stop
stopConsumerGroups
stopProducers
This PR needs to land before I can go back to work on #9
This also changes the internal APIs a little bit to be clearer:
kafka.start
becomeskafka.boot
, since it happens on bootstartConsumerGroups
andstartProducers
methods, instead of exposing the internal data structure to the kafka provider.kafka.disconnect
becomeskafka.stop
— _we could introducestopConsumerGroups
andstopProducers
as well, instead of just a singularkafka.stop
This PR needs to land before I can go back to work on #9