Hi team,
I have a multitenancy use case where data is ingested by kafka and stored in cassandra. Depending on the data, these are stored in different keyspaces (Multi-tenancy with shared database and separate schema).
We currently have an implementation that incorporates multiple cassandra sinks (one for each keyspace), but this implies multiple Cassandra connections.
Looking at the documentation, we have observed that the sink can be configured with a DefaultKeyspace. Is there the possibility of being able to modify that keyspace for each tuple? In this way, we would not need multiple connections with cassandra.