package com.tianbo.messagebus.myinterface;

import com.tianbo.messagebus.controller.response.ResultJson;
import feign.Headers;
import feign.Param;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@FeignClient(name = "kafka-server-consumer",
            fallback = KafkaReciveFallback.class )
public interface KafkaReciveApi {

    @ResponseBody
    @RequestMapping(value = "/kafka/receive",method = RequestMethod.GET)
    ResultJson<List<String>> recive(@RequestParam(value = "username",required = true) String username);
}