Как исправить ошибку Кафки "IOException, возникающая при установлении соединения с https://stream.twitter.com" в Java? - PullRequest
Новая
       45

Как исправить ошибку Кафки "IOException, возникающая при установлении соединения с https://stream.twitter.com" в Java?

0 голосов
/ 26 июня 2019

Используя Kafka, я пытаюсь передать данные из твиттера в Java, но когда я запускаю программу, я получаю эту ошибку: 

[hosebird-client-io-thread-0] WARN com.twitter.hbc.httpclient.ClientBase - Hosebird-Client-01 IOException caught when establishing connection to https://stream.twitter.com/1.1/statuses/filter.json?delimited=length&stall_warnings=true
[hosebird-client-io-thread-0] WARN com.twitter.hbc.httpclient.ClientBase - Hosebird-Client-01 failed to establish connection properly
[hosebird-client-io-thread-0] INFO com.twitter.hbc.httpclient.ClientBase - Hosebird-Client-01 Done processing, preparing to close connection
  1. Я пытаюсь получить потоки для определенного элемента хэштега. Я проверил зависимость в pom.xml 
<dependency>
  <groupId>com.twitter</groupId>
  <artifactId>hbc-core</artifactId> 
  <version>2.2.0</version>
</dependency>
  1. Запустив команду curl, я получаю следующее сообщение: 
$ curl -I https://stream.twitter.com
HTTP/1.1 404 Not Found
content-length: 0
date: Wed, 26 Jun 2019 13:28:19 GMT
server: tsa_a
set-cookie: personalization_id="v1_HSs6Yj5MLa8Ct13KsRWj3A=="; Max-Age=63072000; Expires=Fri, 25 Jun 2021 13:28:19 GMT; Path=/; Domain=.twitter.com
set-cookie: guest_id=v1%3A156155569958747022; Max-Age=63072000; Expires=Fri, 25 Jun 2021 13:28:19 GMT; Path=/; Domain=.twitter.com
strict-transport-security: max-age=631138519
x-connection-hash: 567cd8537e0e96252c2175e59d752883
x-response-time: 2
  1. и попытался восстановить ключи и токены.

Вот фрагмент кода: 

public void run(){

// Setting blocking queues
BlockingQueue<String> msgQueue = new LinkedBlockingQueue<String>(1000);

// create a twitter client
Client client = createTwitterClient(msgQueue);

// Establish a connection.
client.connect();

// looping thru code
// etc
}

public Client createTwitterClient(BlockingQueue<String> msgQueue){

// Declared the keys and tokens

// Host to connect to, the endpoint, and authentication (basic auth or oauth) */

Hosts hosebirdHosts = new HttpHosts(Constants.STREAM_HOST); <- this guy
StatusesFilterEndpoint hosebirdEndpoint = new StatusesFilterEndpoint();

// rest of the code for ClientBuilder and Client
}

Где Constants.STREAM_HOST: 

public static final String STREAM_HOST = "https://stream.twitter.com";

Я ожидаю, что соединение будет установлено и я смогу получать твиты. По какой причине STREAM_HOST не устанавливает соединение?

1 Ответ

0 голосов
/ 27 июня 2019

Спасибо тем, кто даже читает мои вопросы.

Кажется, это происходит из-за настроек брандмауэра моего ноутбука. Я попробовал точно такой же код с другим менее защищенным ноутбуком, и он работает как шарм. Нужно будет разобраться с админом.

...