前段时间在项目中把用到kafka组件完全剥离开出来，项目需要可以直接集成进去。源代码如下：
exercise/netcore.demo/NC.EntityFramework at master · liuzhixin405/exercise (github.com)
组件结构如下，代码太多不一一列举，可以去git上看：
使用规则如下：
1、新建消费事件和生产服务
2、program中引入即可
.UseMessageBus( (serviceProvider) => new List<IProducer>() { new Producer<SendOrderEvent>() } , (serviceProvider) => new List<IConsumer>() { new Consumer<SendOrderEvent, MessageBusTestHandler>($"{ConstDefine.Messagebus_SendOrderTopic}", "SendOrderPersistence") } )
原文：https://www.cnblogs.com/morec/p/15222587.html