Response status=401 Unauthorized

[liuyangandy]

I download the source code and try to run it on my local, Kafka and zookeeper are also installed on my localhost. I found the following error message when I try to send message via Kafka producer.

916 [default-akka.actor.default-dispatcher-4] DEBUG org.apache.kafka.clients.producer.internals.Metadata - Updated cluster metadata version 1 to Cluster(nodes = [Node(localhost, 9092)], partitions = [])
1372 [default-akka.actor.default-dispatcher-4] DEBUG org.apache.kafka.clients.producer.KafkaProducer - Kafka producer started
1372 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.producer.internals.Sender - Starting Kafka producer I/O thread.
[INFO] [05/17/2017 15:39:56.354] [default-akka.actor.default-dispatcher-3] [akka://default/user/$b] Sending query request to https://stream.twitter.com/1.1/statuses/filter.json?track=Hello
36070 [default-akka.actor.default-dispatcher-3] INFO core.OAuth$ - request HttpEntity(application/x-www-form-urlencoded,track=Hello)
[INFO] [05/17/2017 15:41:15.755] [default-akka.actor.default-dispatcher-4] [akka://default/user/$b] Response status=401 Unauthorized
[ERROR] [05/17/2017 15:41:15.773] [default-akka.actor.default-dispatcher-4] [akka://default/user/$b] Request failed, backoff=10
[INFO] [05/17/2017 15:41:15.804] [default-akka.actor.default-dispatcher-5] [akka://default/system/IO-TCP/selectors/$a/0] Message [akka.io.Tcp$Write] from Actor[akka://default/user/IO-HTTP/group-0/0#-1297152897] to Actor[akka://default/system/IO-TCP/selectors/$a/0#1959660077] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[INFO] [05/17/2017 15:41:15.805] [default-akka.actor.default-dispatcher-5] [akka://default/system/IO-TCP/selectors/$a/0] Message [akka.io.Tcp$ConfirmedClose$] from Actor[akka://default/user/IO-HTTP/group-0/0#-1297152897] to Actor[akka://default/system/IO-TCP/selectors/$a/0#1959660077] was not delivered. [2] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[INFO] [05/17/2017 15:41:25.848] [default-akka.actor.default-dispatcher-3] [akka://default/user/$b] Sending query request to https://stream.twitter.com/1.1/statuses/filter.json?track=Hello
151897 [default-akka.actor.default-dispatcher-3] INFO core.OAuth$ - request HttpEntity(application/x-www-form-urlencoded,track=Hello)

[liuyangandy]

This issue was already fixed!

[kmillanrfractal]

how?