Is it possible to throttle the kafka consumer

(Joo) #1

Hello all,

Is it possible to put the throttle in the Kafka topic consumer in lagom?
I know we can control the parallelism but is it also possible to introduce the time delay in between the message processing?
i.e. delay 100ms after between each process.

(Patrik Nordwall) #2

You provide an Akka Streams Flow to consume the messages, right? Then you can add a throttle operator to the flow to slow it down.

1 Like
(Joo) #3

Thanks Patrik. Yes, I figured that out after uploading this post. haha… thanks!