[GitHub] [camel-k] nicolaferraro commented on issue #1779: KameletBiding : support for partitions for sources

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org