ssl - 如何为 tibco JMS ssl 配置水槽

Question

我正在使用 tibco JMS 作为水槽的来源，想知道如何为此启用 SSL。在文档中，我看到对于其他类型的源，ssl 应该设置为 true。我没有看到 JMS 的这个 ssl 属性。请帮助我配置 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 = <queuename>
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=<keystore password>
a1.sources.r1.keystore-type=<keystore type>

请帮我解决这个问题。谢谢。

Answer 1

目前 Flume JMS Source 没有这个功能。 Flume Avro 源码有这个。

https://github.com/apache/flume/blob/trunk/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java

您可以引用上述类并编写一个类似于上述类的自定义 JMS 源。