我想用 JMS
的来源 flume
. 我将其配置如下:
...
# Source Definition
a1.sources.r1.type = jms
a1.sources.r1.initialContextFactory =
org.apache.activemq.jndi.ActiveMQInitialContextFactory
a1.sources.r1.providerURL = tcp://<ipAddress>:<port>
a1.sources.r1.destinationName = QA.TEST.NAME
a1.sources.r1.destinationType = QUEUE
...
我已经设置了Flume Cloudera
,因此所有配置都是使用全局多示例ui完成的。我将Flume服务环境设置如下:
...
FLUME_CLASSPATH= .../cloudera/parcels/CDH/lib
jms源jar所在的位置。虽然我得到以下错误:
Failed to start agent because dependencies were no found in classpath. Error follows: java.lang.NoClassDefFoundError: javax/jms/JMSException
...
有什么建议吗?
暂无答案!
目前还没有任何答案,快来回答吧!