Spring Cloud Gateway with Kafka Broadcaster

Question

我正在做一个spring-cloud-gateway和kafka广播器的项目。该项目使用spring-cloud-gateway，这意味着没有任何控制器。使用spring-cloud-gateway将请求转发到另一个微服务。

我的问题是，我需要发送一个消息到kafka主题。我知道有一些关于spring-cloud-gateway的amazon sqs和sns的例子。有使用kafka和spring-cloud-gateway的例子吗?

Answer 1

您可以使用本教程

@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();
}
}