package com.tianbo.messagebus.myinterface;

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


@FeignClient(name = "kafka-server-consumer",
            url = "http://127.0.0.1:8088/",
            fallback = KafkaReciveFallback.class )
public interface KafkaReciveApi {

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