我正在使用tibcojms作为flume的源代码，并想知道如何为此启用ssl。在我看到的文档中 ssl 应设置为 true 对于其他类型的源。我没看到这个 ssl jms的属性。请帮助我配置要使用的jms源代码 ssl ```
agent.sources.mySrc.type = jms
agent.sources.mySrc.initialContextFactory = com.tibco.tibjms.naming.TibjmsInitialContextFactory
agent.sources.mySrc.providerURL = tibjmsnaming://mysever:port
agent.sources.mySrc.destinationName =
agent.sources.mySrc.destinationType = queue
agent.sources.mySrc.batchSize=50
agent.sources.mySrc.connectionFactory = QueueConnectionFactory
agent.sources.mySrc.userName=user
agent.sources.mySrc.passwordFile=/opt/flume/conf/password.txt
agent.sources.mySrc.converter.type=org.apache.flume.source.jms.ELFJMSMessageEventUUIDConverter$Builder
agent.sources.mySrc.selector.type = multiplexing
agent.sources.mySrc.selector.header=zone
这是我的jms，我想知道jms源是否有如下属性SSL properties for Thrift source s1
a1.sources.r1.ssl=true
a1.sources.r1.keystore=<path/to/keystore>
a1.sources.r1.keystore-password=
a1.sources.r1.keystore-type=
请帮我解决这个问题。谢谢。
1条答案
按热度按时间oyxsuwqo1#
当前flume jms源没有此功能。Flumeavro源有这个。
https://github.com/apache/flume/blob/trunk/flume-ng-core/src/main/java/org/apache/flume/source/avrosource.java
您可以引用上述类并编写类似于上述类的自定义jms源代码。