Closed agalue closed 3 years ago
As explained in Issue #9, this will add support for Kafka as a supported broker.
It uses Watermill/Sarama as an implementation.
It works with some caveats, and currently, three is no way to pass consumer/producer settings, but this can be implemented later.
As explained in Issue #9, this will add support for Kafka as a supported broker.
It uses Watermill/Sarama as an implementation.
It works with some caveats, and currently, three is no way to pass consumer/producer settings, but this can be implemented later.