search

confluentinc / kafka-rest-node

Node.js client for the Kafka REST proxy
Apache License 2.0
0 stars 40 forks source link

Is this repository still being maintained? #31

Open vunguyenhung opened 7 years ago

vunguyenhung commented 7 years ago

Hello, I'm very excited when a big guy like Confluentinc implement Kafka-rest client library for node. But it seems not working properly because every request to server make Kafka throws InvalidReceiveException. Therefore I wonder whether this repository is still being maintained or not?

BTW, here is the stacktrace:

[2017-09-27 12:23:50,115] WARN Unexpected error from /172.18.0.6; closing connection (org.apache.kafka.common.network.Selector)
org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104857600)
at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:95)
at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:75)
at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:203)
at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:167)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:381)
at org.apache.kafka.common.network.Selector.poll(Selector.java:326)
at kafka.network.Processor.poll(SocketServer.scala:500)
at kafka.network.Processor.run(SocketServer.scala:435)
at java.lang.Thread.run(Thread.java:745)

when I'm trying to call kafka.brokers.list().

Docker containers I'm using: 

8414f70f40f8        confluentinc/cp-kafka-rest:3.3.0        "/etc/confluent/do..."   22 minutes ago      Up 22 minutes       0.0.0.0:8082->8082/tcp                       tos_kafka-rest_1
3beaa2c41c1e        confluentinc/cp-schema-registry:3.3.0   "/etc/confluent/do..."   22 minutes ago      Up 22 minutes       0.0.0.0:8081->8081/tcp                       tos_schema-registry_1
447f26233264        confluentinc/cp-kafka:3.3.0             "/etc/confluent/do..."   22 minutes ago      Up 22 minutes       0.0.0.0:9092->9092/tcp                       tos_kafka_1
9ca96e4ca75c        confluentinc/cp-zookeeper:3.3.0         "/etc/confluent/do..."   22 minutes ago      Up 22 minutes       2888/tcp, 0.0.0.0:2181->2181/tcp, 3888/tcp   tos_zookeeper_1

Thank you for reading this.

mihir83in commented 6 years ago

+1

Bconteh commented 5 years ago

@vunguyenhung @mihir83in Any update on this issue? I'm having the same error on 5.0.1 version as well

yunnysunny commented 5 years ago

The problem's reason is that the message size you send is greater than the max size limit, which is 1MB default.