You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 

21 lines
513 B

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Threading.Tasks;
  5. using Cap.Consistency.Attributes;
  6. using Cap.Consistency.Consumer;
  7. using Microsoft.AspNetCore.Mvc;
  8. namespace Sample.Kafka.Controllers
  9. {
  10. [Route("api/[controller]")]
  11. public class ValuesController : Controller, IConsumerService
  12. {
  13. [KafkaTopic("zzwl.topic.finace.callBack", IsOneWay = true)]
  14. public void KafkaTest() {
  15. Console.WriteLine("kafka test invoked");
  16. }
  17. }
  18. }