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
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
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
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
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
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
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.