You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Yang Cui <yc...@freewheel.tv> on 2017/04/26 12:00:18 UTC
About "org.apache.kafka.common.protocol.types.SchemaException"
Problem
Dear All,
I am using Kafka cluster 2.11_0.9.0.1, and the new consumer of 2.11_0.9.0.1.
When I set the quota configuration is:
quota.producer.default=1000000
quota.consumer.default=1000000
And I used the new consumer to consume data, then the error happened sometimes:
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'responses': Error reading array of size 1140343, only 37 bytes available
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:73)
at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:439)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:265)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:320)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:213)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:193)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:908)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853)
at com.fw.kafka.ConsumerThread.run(TimeOffsetPair.java:458)
It is not occurred every time, but when it happened, it occurs repeatedly many times.
答复: About "org.apache.kafka.common.protocol.types.SchemaException" Problem
Posted by Hu Xi <hu...@hotmail.com>.
Seems it's similar to https://issues.apache.org/jira/browse/KAFKA-4599?
________________________________
发件人: Yang Cui <yc...@freewheel.tv>
发送时间: 2017年4月27日 11:55
收件人: users@kafka.apache.org
主题: Re: About "org.apache.kafka.common.protocol.types.SchemaException" Problem
Hi All,
Have anyone can help answer this question? Thanks a lot!
On 26/04/2017, 8:00 PM, "Yang Cui" <yc...@freewheel.tv> wrote:
Dear All,
I am using Kafka cluster 2.11_0.9.0.1, and the new consumer of 2.11_0.9.0.1.
When I set the quota configuration is:
quota.producer.default=1000000
quota.consumer.default=1000000
And I used the new consumer to consume data, then the error happened sometimes:
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'responses': Error reading array of size 1140343, only 37 bytes available
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:73)
at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:439)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:265)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:320)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:213)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:193)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:908)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853)
at com.fw.kafka.ConsumerThread.run(TimeOffsetPair.java:458)
It is not occurred every time, but when it happened, it occurs repeatedly many times.
Re: About "org.apache.kafka.common.protocol.types.SchemaException"
Problem
Posted by Yang Cui <yc...@freewheel.tv>.
Hi All,
Have anyone can help answer this question? Thanks a lot!
On 26/04/2017, 8:00 PM, "Yang Cui" <yc...@freewheel.tv> wrote:
Dear All,
I am using Kafka cluster 2.11_0.9.0.1, and the new consumer of 2.11_0.9.0.1.
When I set the quota configuration is:
quota.producer.default=1000000
quota.consumer.default=1000000
And I used the new consumer to consume data, then the error happened sometimes:
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'responses': Error reading array of size 1140343, only 37 bytes available
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:73)
at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:439)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:265)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:320)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:213)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:193)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:908)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853)
at com.fw.kafka.ConsumerThread.run(TimeOffsetPair.java:458)
It is not occurred every time, but when it happened, it occurs repeatedly many times.