package com.tianbo.messagebus.myinterface;

import com.tianbo.messagebus.controller.response.ResultJson;
import com.tianbo.messagebus.model.MSGS;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@FeignClient(name = "kafka-server-producer",
            fallback = KafkaSendFallback.class )
public interface KafkaSendApi {

    @ResponseBody
    @RequestMapping(value = "/kafka/send",method = RequestMethod.POST)
    ResultJson send(@RequestBody MSGS msgs);
}