We have a multi-tenancy scenario where: - the source will be Kafka, and a Kafka partition could contain data from multiple tenants - our sink will send data to a different DB instance, depending on the tenant
Is there a way to prevent slowness in one tenant from slowing other tenants, without assigning kafka partitions to tenants? My understanding is that the answer is "no", but I'm curious whether I'm missing a cool way to accomplish this. In the absence of such a way, I 'believe' that slowness in one tenant’s DB instance will cause backpressure all the way back to the source (Kafka partition), and thus Flink will slow its reading from the given Kafka partition, thus also impacting the rest of the tenants that reside in that Kafka partition.
