using Confluent.Kafka;

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