using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace JiShe.CollectBus.Kafka.Internal { /// /// Kafka订阅者 /// /// 订阅者需要继承此接口并需要依赖注入,并使用标记 /// /// public interface IKafkaSubscribe { } }