You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Perhaps I'm missing something super obvious, but I'm struggling to get it to work.
I have a kafka message that:
has value:
{
"message": "hello there reid"
}
has kafka headers:
{
"myheader": "myheadervalue"
}
and has a key:
"some-key"
and I have a sql insert like:
camel.kamelet.postgresql-sink.query: 'INSERT INTO mytable (message,other) VALUES (:#message,:#${header.kafka.KEY})'
this doesn't inject anything into header.kafka.KEY, weirdly.
I'm trying to do something like:
camel.kamelet.postgresql-sink.query: 'INSERT INTO mytable (message,mykey,myheader) VALUES (:#message,:#${kafka.key},:#${kafka.header.myheader})', but no luck yet.
All of the examples for db sinks are like:
INSERT INTO accounts (username,city) VALUES (:#username,:#city)
where the username and city are key names in the json message from the kafka.
Is it possible to insert the kafka key or a kafka header (which is also json)?
The text was updated successfully, but these errors were encountered: