cjmamo / kafka-web-console

A web console for Apache Kafka (retired)
Apache License 2.0
762 stars 246 forks source link

Topic feed not working #13

Open manishdh opened 10 years ago

manishdh commented 10 years ago

Hi,

I have installed web console on centos. I have created topics and producer I can see the messages in terminal consumers but no able to see topic feed on web console. I am not sure id this is websocket issue.

curl -i -N -H "Connection: Upgrade" -H "Upgrade: websocket" -H "Host: localhost" -H "Origin: http://localhost:9000" http://127.0.0.1:9000/#/topics/apache_log/webevent HTTP/1.1 200 OK Content-Type: text/html; charset=utf-8 Content-Length: 4323

if i do

curl -i -N -H "Connection: Upgrade" -H "Upgrade: websocket" -H "Host: echo.websocket.org" -H "Origin: http://www.websocket.org" http://echo.websocket.org HTTP/1.1 101 Web Socket Protocol Handshake Upgrade: WebSocket Connection: Upgrade WebSocket-Origin: http://www.websocket.org WebSocket-Location: ws://echo.websocket.org/ Server: Kaazing Gateway

Also I get this error on kafka broker log when I refresh topic feed page.

INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor) [2014-04-12 06:30:25,801] ERROR Closing socket for /127.0.0.1 because of error (kafka.network.Processor) java.io.IOException: Connection reset by peer

Thanks. Manish.

jrosengren commented 10 years ago

FYI - just deployed the kafka-web-console on our development Kafka instance and am seeing the same issue.

Using a git clone from today (7/29/2014) and have created a standalone dist for deployment - running against ZK 3.4.6 and Kafka 0.8.1.1

cjmamo commented 10 years ago

This will be a tough one to replicate but I'll give it a go.

jrosengren commented 10 years ago

When I try to browse the Topic Feed for any topic, I see the following error in the Kafka logs:

[2014-07-30 14:40:42,674] ERROR Closing socket for /10.171.46.208 because of error (kafka.network.Processor)
java.io.IOException: Connection reset by peer
        at sun.nio.ch.FileDispatcher.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:198)
        at sun.nio.ch.IOUtil.read(IOUtil.java:171)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:245)
        at kafka.utils.Utils$.read(Utils.scala:375)
        at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
        at kafka.network.Processor.read(SocketServer.scala:347)
        at kafka.network.Processor.run(SocketServer.scala:245)
        at java.lang.Thread.run(Thread.java:662)