Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

don't die terribly when Kafka isn't available #4

Closed
codefromthecrypt opened this issue Jul 23, 2016 · 2 comments
Closed

don't die terribly when Kafka isn't available #4

codefromthecrypt opened this issue Jul 23, 2016 · 2 comments

Comments

@codefromthecrypt
Copy link
Member

I noticed the current setup hates when Kafka is down. We need some tests that actually use kafka, and show that it doesn't hose the process when it is unavailable.

20:05:37.005 [kafka-producer-network-thread | producer-1] WARN  o.a.kafka.common.network.Selector - Error in I/O with /192.168.99.100
java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
    at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
    at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
    at java.lang.Thread.run(Thread.java:745)
20:05:37.109 [kafka-producer-network-thread | producer-1] WARN  o.a.kafka.common.network.Selector - Error in I/O with /192.168.99.100
java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
    at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
    at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
    at java.lang.Thread.run(Thread.java:745)
20:05:37.213 [kafka-producer-network-thread | producer-1] WARN  o.a.kafka.common.network.Selector - Error in I/O with /192.168.99.100
java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
    at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
    at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
    at java.lang.Thread.run(Thread.java:745)
@codefromthecrypt codefromthecrypt mentioned this issue Aug 3, 2016
Closed
codefromthecrypt pushed a commit that referenced this issue Aug 19, 2016
Moves to zipkin-reporter-java and zipkin 1.7
ba75344 
This moves off the interim storage classes to reporter-specific ones.
By doing so, it is easier to add support for pre-canned reporters.

Fixes #4
@codefromthecrypt codefromthecrypt mentioned this issue Aug 19, 2016
Merged
codefromthecrypt pushed a commit that referenced this issue Aug 19, 2016
@adriancole
Moves to zipkin-reporter-java and zipkin 1.7 (#16)
720ee9b 
This moves off the interim storage classes to reporter-specific ones.
By doing so, it is easier to add support for pre-canned reporters.

Fixes #4
@codefromthecrypt
Copy link
Member Author

we need to solve this more permanently

@codefromthecrypt
Copy link
Member Author

test is in now

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@codefromthecrypt