Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.

16 lines
449B

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading.Tasks;
  6. namespace NearCardAttendance.Service.MessageQueue.Kafka
  7. {
  8. public interface IKafkaService
  9. {
  10. Task PublishAsync<T>(string topicName, T message) where T : class;
  11. Task SubscribeAsync<T>(IEnumerable<string> topics, Action<T> messageFunc, CancellationToken cancellationToken = default) where T : class;
  12. }
  13. }