我正在尝试将我的Apache Flume
应用程序源连接到Oracle AQ
。 jndi.properties
位于类路径中,并按如下方式配置:
java.naming.factory.initial=oracle.jms.AQjmsInitialContextFactory
java.naming.provider.url=tcp://my.db.url
java.naming.security.principal=remote
java.naming.security.credentials=remotepwd
我在日志中收到以下错误:
Source jmsSource has been removed due to an error during configuration
org.apache.flume.FlumeException: Could not create initial context oracle.jms.AQjmsInitialContextFactory provider tcp://my.db.url
....
Caused by: javax.naming.NamingException: The configuration of the AQjmsInitialContext is not complete.
The configuration must contain datasource or (db_url,java.naming.security.principal,java.naming.security.credentials) or both
我已经从示例中复制了java.naming.security.principal=remote
java.naming.security.credentials=remotepwd
,但我真的不知道我需要插入哪些值。
关于如何正确配置jndi.properties
文件的任何建议?
根据错误消息(在我查看源代码之前我也不清楚),db url 是通过 db_url
属性指定的。所以你想要类似的东西
java.naming.factory.initial=oracle.jms.AQjmsInitialContextFactory
db_url=tcp://my.db.url
java.naming.security.principal=remote
java.naming.security.credentials=remotepwd