如何在Camel kafka选项参数中设置地图

Question

我们在camel kafka选项中有称为附加属性的属性，其类型为map

 return "kafka:" + topic + "?brokers= " + host + "&groupId=" + group + "&securityProtocol=SASL_SSL"
                + "&saslJaasConfig=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;"
                + "&saslMechanism=OAUTHBEARER"
                + "&sslTruststorePassword=changeit"
                + "&additionalProperties=AuthProvider"
                + "&sslTruststoreLocation=" + "truststore.jks"

预期是地图类型&因为我们使用字符串uri构建它，那么我们如何在上面的camel kafka选项参数中传递地图。

Answer 1

Camel Kafka 组件文档给出了如何配置的示例

additionalProperties

：

https://camel.apache.org/components/4.4.x/kafka-component.html#_endpoint_query_option_additionalProperties

您可以在每个选项前加上

additionalProperties.

前缀，后跟要配置的 Kafka 属性的名称。例如。

from("kafka:myTopic?additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro")