TelpoPushThirdSsl/TelpoPush.Service/Mq/Kafka/IKafkaService.cs

using Confluent.Kafka;

namespace TelpoPush.Service.Mq.Kafka
{
    public interface IKafkaService
    {
        Task SubscribeAsync(Action<string, string, Headers> messageFunc, CancellationToken cancellationToken);
    }
}