using Cloud.Services.Broker.Support;

namespace Cloud.Services.Broker.Implement.Kafka
{
    public class KafkaService : IBrokerService
    {
        public Task<T> Consume<T>(string topic)
        {
            throw new NotImplementedException();
        }

        public Task<CommandResult> Produce(Command command)
        {
            throw new NotImplementedException();
        }
    }
}