Hi Yeah that is a good question. Dont have super much time to help / investigate this.
Would you create a ticket to add an example at https://github.com/apache/camel-kamelets-examples We should surely make this easier with both camel-kafka component, and especially with the kafka based kamelets. And jbang can help make this easier as you should ideally just configure a few bits. On Thu, Mar 16, 2023 at 1:32 PM Ramesh Venkitaswaran < venkitaswa...@gmail.com> wrote: > Hello > I am testing out camel integration with the confluent schema registry > and trying to consume a message that is avro encoded using a schema > from the schema registry. However, when I run the integration, camel > is issuing a WARN level log message that these properties are not > known configurations. > > Camel version: Apache Camel 3.20.2 > Jbang version: 0.104.0 > > Here is my sample yaml: > > # camel-k: language=yaml > > - from: > uri: "kafka:TOPIC_NAME" > parameters: > brokers: "XXXXXX:9092" > clientId: "laptop" > schemaRegistryURL: "https://url-to-schema-registry"; > additionalProperties.auto.credentials.source: USER_INFO > additionalProperties.basic.auth.user.info: "XXXXXX:XXXXXX" > securityProtocol: SASL_SSL > saslMechanism: PLAIN > saslJaasConfig: > "org.apache.kafka.common.security.plain.PlainLoginModule required > username=XXXXXX password=XXXXXX;" > autoCommitEnable: true > groupId: "example-1" > specificAvroReader: true > steps: > - log: "${body}" > > And here is the relevant log lines > > 2023-03-16 07:14:39.500 INFO 2098 --- [ main] > el.impl.engine.AbstractCamelContext : Routes startup (started:1) > 2023-03-16 07:14:39.500 INFO 2098 --- [ main] > el.impl.engine.AbstractCamelContext : Started route1 > (kafka://IT.SMS.Platform-Events_dev) > 2023-03-16 07:14:39.501 INFO 2098 --- [ main] > el.impl.engine.AbstractCamelContext : Apache Camel 3.20.2 (demo) > started in 200ms (build:51ms init:82ms start:67ms JVM-uptime:1s) > > 2023-03-16 07:14:39.661 WARN 2098 --- [XXXXXX]] > fka.clients.consumer.ConsumerConfig : The configuration > 'specific.avro.reader' was supplied but isn't a known config. > > and > 2023-03-16 07:14:39.661 WARN 2098 --- [XXXXX]] > fka.clients.consumer.ConsumerConfig : The configuration > 'basic.auth.user.info' was supplied but isn't a known config. > > Is there something else I need to configure to be able to deserialize > avro messages? > > Thanks > -- Claus Ibsen ----------------- @davsclaus Camel in Action 2: https://www.manning.com/ibsen2
