Hi,

I have a flink job that consumes from kafka and sinks it to an API. I need
to ensure that my flink job can send within the rate limit 200 tps, we are
planning to increase the parallelism, but I do not know the right number to
set. 1 parallelism  does equal to 1 consumer? So if 200, should we set it
to 200 parallelism too?

I only created a simple retry that will send it again if 421 http error is
received.


Any advise, appreciated. Thanks

Reply via email to