Spring 云门户丨 Kafka播音员

qlzsbp2j  于 2023-03-17  发布在  Apache
关注(0)|答案(1)|浏览(86)

我正在做一个项目,在spring-cloud-gateway和Kafka broadcaster上工作。这个项目使用spring-cloud-gateway,所以这意味着没有任何控制器。通过使用spring-cloud-gateway,请求被转发到另一个微服务。
我的问题是我需要给一个Kafka主题发一条信息。我知道有一些例子是关于亚马逊sqs和sns与spring-cloud-gateway的。有没有使用Kafka和spring-cloud-gateway的例子?

ecbunoof

ecbunoof1#

您可以使用this教程

@SpringBootApplication
@EnableWebSocketMessageBroker
public class MicroserviceWebApplication extends AbstractWebSocketMessageBrokerConfigurer {
    public static void main(String[] args) {
        System.setProperty("spring.devtools.restart.enabled", "true");
        SpringApplication.run(MicroserviceWebApplication.class, args);
    }
   @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {

        registry.addEndpoint("/ws").setAllowedOrigins("*").withSockJS();
    }
}

相关问题