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
