[ 
https://issues.apache.org/jira/browse/FLINK-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15105195#comment-15105195
 ] 

Maximilian Michels commented on FLINK-3248:
-------------------------------------------

Yes, that approach is more future proof. I would use Kryo.

> RMQSource does not provide a constructor for credentials or other options
> -------------------------------------------------------------------------
>
>                 Key: FLINK-3248
>                 URL: https://issues.apache.org/jira/browse/FLINK-3248
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming Connectors
>    Affects Versions: 1.0.0
>            Reporter: Maximilian Michels
>            Assignee: Maximilian Michels
>             Fix For: 1.0.0
>
>
> We could either add a new constructor for credentials (username and password) 
> or let the user pass a {{ConnectionFactory}} to the source. The latter would 
> enable us to support all potential options for the connection. Note that, 
> {{ConnectionFactory}} is not serializable. It would have to be serialized to 
> a byte array for shipping.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to