nicolaferraro commented on issue #1779:
URL: https://github.com/apache/camel-k/issues/1779#issuecomment-715074973
I think we can keep using the same model that we have now, like:
```yaml
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: jdbc-source
spec:
source:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: jdbc-source
properties:
tables:
- table1
- table2
- table3
sink:
ref:
kind: KafkaTopic
apiVersion: kafka.strimzi.io/v1beta1
name: my-topic
```
The information that tells the operator that "tables" is a partition key is
present on the kamelet, e.g. with a `x-camel-partition-key` flag in the
descriptor.
The assignment of partition and rebalancing can be also done with a modified
version of the master component instead of StatefulSets, to make it more
dynamic.
Wdyt?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
