Re: Support/connector for Neo4j?

2017-03-24 Thread alex.decastro
Thanks Tim! I missed that one on Jira. :-) -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Support-connector-for-Neo4j-tp12397p12399.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Support/connector for Neo4j?

2017-03-24 Thread alex.decastro
Any pointers for current hacks (from Flink users) on how to fetch table data from Neo4j? Any plans on the roadmap to include a Neo4j connector? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Support-connector-for-Neo4j-tp12397.html Sent fro

Re: #kafka/#ssl: how to enable ssl authentication for a new kafka consumer?

2017-02-09 Thread alex.decastro
Cool, thanks. Just checked it. One last question: if the server hosting my Kafka broker has only SSL enabled, but not SASL (Kerberos) how to go about enabling connection authentication between client consumer and broker? Same for data transfer? -- View this message in context: http://ap

Re: #kafka/#ssl: how to enable ssl authentication for a new kafka consumer?

2017-02-09 Thread alex.decastro
I found a similar question and answer at #stackoverflow http://stackoverflow.com/questions/37743194/local-flink-config-running-standalone-from-ide Verify? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/kafka-ssl-how-to-enable-ssl-authenti

Re: #kafka/#ssl: how to enable ssl authentication for a new kafka consumer?

2017-02-09 Thread alex.decastro
Thanks Robert. As a beginner Flinker, hot to tell my Flink app (in Intellij say) where the flink-conf.yaml is. Alex -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/kafka-ssl-how-to-enable-ssl-authentication-for-a-new-kafka-consumer-tp115

#kafka/#ssl: how to enable ssl authentication for a new kafka consumer?

2017-02-08 Thread alex.decastro
Dear flinkers, I'm consuming from a kafka broker in a server that has ssl authentication enabled? How do I config my consumer to compy with it? Many thanks Alex -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/kafka-ssl-how-to-enable-ssl-au

Re: scala version of flink mongodb example

2017-02-07 Thread alex.decastro
Hi there, treading in the thread, do you know how to add authentication options to mongo here? I'm trying to do hdIf.getJobConf.set("user", s"$USER") hdIf.getJobConf.set("password", s"$PWD") but I can't find any documentation to support it. Any pointers? Many thanks, Alex -- View th