Messaging support about spring-cloud-gateway HOT 10 OPEN

No I don't

from spring-cloud-gateway.

/cc @dsyer @markfisher @mbogoevici

from spring-cloud-gateway.

I realized lookup/discovery for message push routing on client via eureka ClientDiscovery lookup against eureka server. Client reads known metadata fields like broker url, topic, queue, etc that is published by broker-registry-service in the name iof the broker istelf (e.g.rabbitmq/kafka)

Using spring cloud gateway as http gatway to any backend message broker tha would be possible by
extracting destination from url (e.g. /application/topic/ ) and the using the lookup from destination from eureka (metadata) or even coupled with fowarding (http->message queue/topic..) - however mixing protocols seems no good idea to me.

from spring-cloud-gateway.

Apologies for the drive-by necrothreading, I've hit a few cases where I've wished for this capability:

• Wrapping an HTTP API over Kafka: receiving at a front end proxy, writing into Kafka, picking up from a back end proxy and replaying the HTTP request into the target API.
• Providing a simple events gateway. Specifically, I'd like to have an easy way to listen for webhooks that then spit out CloudEvents into a Knative Eventing setup.

I've overheard others wondering if this was possible. On some brief spelunking of the code I suspect it would be a fairly hefty project to create this sort of capability, but that's never stopped me from whining before.

from spring-cloud-gateway.

No worries, we spoke about this recently. It could be done with spring integration I'm sure

from spring-cloud-gateway.

Why not Spring Cloud Stream? It’s kind of trivial. In fact it’s a stock Spring Cloud Dataflow feature isn’t it? Caveat: request-response is not a great messaging pattern, so Spring Cloud Stream makes it hard - you might need to drop down to Spring Integration to do that.

from spring-cloud-gateway.

No worries, we spoke about this recently. It could be done with spring integration I'm sure

Hi @spencergibb , when release feature?
I am also developing this feature.

from spring-cloud-gateway.

It's not currently being worked on

from spring-cloud-gateway.

It's not currently being worked on

Hi @spencergibb ,
do you have any idea for this feature?

from spring-cloud-gateway.

This would be a nice feature, a quick back-pressure implementation. I created a custom filter to do this (with spring kafka), but I have memory issues with large payloads (700ko).

@Override public GatewayFilter apply(Config config) { return (exchange, chain) -> ServerWebExchangeUtils.cacheRequestBodyAndRequest(exchange, (httpRequest) -> ServerRequest.create(exchange.mutate().request(httpRequest).build(), messageReaders).bodyToMono(String.class).doOnNext(requestPayload -> { final DemandeComparaison requestBody = getRequestBody(requestPayload); exchange.getAttributes().put(ServerWebExchangeUtils.CACHED_REQUEST_BODY_ATTR, requestBody); kafkaProducerService.send(config, requestBody); exchange.getResponse().setComplete(); })); }

I use KafkaTemplate so I have to extract the payload but I wish I could stream the payload directly to the topic. I d'ont know much about Spring Cloud Stream but maybe this would be the way ?

from spring-cloud-gateway.