0
我遵循cloudera的教程（http://blog.cloudera.com/blog/2012/09/analyzing-twitter-data-with-hadoop/）爲應用程序使用Apache Flume將Twitter數據攝入HDFS。 Twitter僅在2014年1月15日起纔將其api連接限制在SSL/TLS上。在此更改之後，我的Flume代理已停止傳輸Twitter數據。 如果您已根據以下文章中的規格實施相應更改以滿足新要求，請回復。後，我安裝twitter4j即v 3.0.3正在使用HTTPS的新版本 https://dev.twitter.com/docs/security/using-sslApache Flume在Twitter API SSL/TLS強制性要求之後停止流式傳輸Twitter數據。
感謝， Hussnain
張貼一些代碼。如果你遵循一些教程，你應該寫一些代碼。 – nestedloop
我的flume.conf有以下源代碼\ n TwitterAgent.sources.Twitter.type = com.cloudera.flume.source.TwitterSource TwitterAgent.sources.Twitter.channels = MemChannel TwitterAgent.sources.Twitter.consumerKey = TwitterAgent.sources.Twitter.consumerSecret = <我的消費者密鑰> TwitterAgent.sources.Twitter.accessToken = <我的訪問令牌> TwitterAgent.sources.Twitter.accessTokenSecret = <我的訪問令牌密鑰> –
Hussnain
TwitterSource文件已以下代碼訪問
public void configure（Context context）{0} {0} {0} {0} consumerKey = context.getString（TwitterSourceConstants.CONSUMER_KEY_KEY）; consumerSecret = context.getString（TwitterSourceConstants.CONSUMER_SECRET_KEY）; accessToken = context.getString（TwitterSourceConstants.ACCESS_TOKEN_KEY）; accessTokenSecret = context.getString（TwitterSourceConstants.ACCESS_TOKEN_SECRET_KEY）; String keywordString = context.getString（TwitterSourceConstants.KEYWORDS_KEY，「」）; – Hussnain