Hi
Im looking for a generic http endpoint which can accept any json request and pushes to kafka.
Depending on your validation requirements, you could create an Akka HTTP route that just accepts the request as a String and pushes that to Kafka using Alpakka Kafka. Are there any particular parts of the application that you’re having trouble with?
Yes, how the multi deployments ( Kubernetes) handle the grpc requests ? Specially if the request is client side streaming ?
A (streaming) gRPC request is bound to one TCP connection, so the elements will flow over a TCP connection from the client to one of the deployed nodes.
how can i leverage sharding in case of gRPC streaming ?