You can add a delay to slow down consumption, but it's best to do that in the code that's deserializing the records from Kafka. That's running in a separate thread, so your delay won't block other work being done by the subtask thread.