Sure. Where would I make this ticket at? Is there a JIRA board link that I can get? -- Ramesh
On Fri, Mar 17, 2023 at 11:02 AM Claus Ibsen <claus.ib...@gmail.com> wrote: > > 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
