Hi You can use a topic pattern (I think its regexp) to consume from multiple topics.
That is in the general camel-kafka component https://camel.apache.org/components/3.17.x/kafka-component.html#_component_option_topicIsPattern I am not sure if they have exposed that in the kafka kamelet. Then the actual topic name is part of a header in the message, so you know the name, which you can then use in your SQL insert statement. On Tue, May 24, 2022 at 9:04 AM shiva kumar g.v <shiv.pe...@gmail.com> wrote: > Hi Team, > > We have a requirement to sync table records between 2 database . We use > strimzi kafka and debezium source connector for CDC. > > Now we have records from 100 tables into 100 topics in kafka which need to > be inserted into target database. > > I was trying to use camel sql server/Jdbc sink connector . Can i create a > single kafka connector CRD to read from all topics and insert into database > tables? Or do I have to create 100 camel kafka connector files since I > need to include query and topic in configuration? > > Any example of sink connector config for my use case would be helpful. > > Thanks, > Shiva > -- Claus Ibsen ----------------- http://davsclaus.com @davsclaus Camel in Action 2: https://www.manning.com/ibsen2
