获取数据时出现意外错误代码 13 Spring-Cloud-Stream Kafka Azure 事件中心 -
Unexpected error code 13 while fetching data Spring-Cloud-Stream Kafka Azure event hub -
12 月 18 日突然弹出这个问题,一直工作正常,找不到任何线索,为什么在正常工作 6 个月后突然不断出现这个异常。
我无法在本地独立复制,但它出现在带有 微服务 的 docker 图像中,其中之一与 [=23= 通信]Azure 偶中心.
我搜索并找到了这个 。在此 post 中也报告了我面临的相同问题,但找不到任何解决方案或线索,所以我 post 提出这个问题。
请参考以下堆栈跟踪:
Error while processing: null
java.lang.IllegalStateException: Unexpected error code 13 while fetching data
at org.apache.kafka.clients.consumer.internals.Fetcher.parseCompletedFetch(Fetcher.java:891)
at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:528)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1154)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1111)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:699)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
如果有任何线索请提出。
最近发生了一个变化,UnknownServerException 的一个实例被更改为 NetworkException - 这无意中改变了消费者客户端的重试行为。在此处提交问题 - https://github.com/Azure/azure-event-hubs-for-kafka/issues - 使用您的命名空间信息。谢谢!
12 月 18 日突然弹出这个问题,一直工作正常,找不到任何线索,为什么在正常工作 6 个月后突然不断出现这个异常。
我无法在本地独立复制,但它出现在带有 微服务 的 docker 图像中,其中之一与 [=23= 通信]Azure 偶中心.
我搜索并找到了这个
请参考以下堆栈跟踪:
Error while processing: null
java.lang.IllegalStateException: Unexpected error code 13 while fetching data
at org.apache.kafka.clients.consumer.internals.Fetcher.parseCompletedFetch(Fetcher.java:891)
at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:528)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1154)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1111)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:699)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
如果有任何线索请提出。
最近发生了一个变化,UnknownServerException 的一个实例被更改为 NetworkException - 这无意中改变了消费者客户端的重试行为。在此处提交问题 - https://github.com/Azure/azure-event-hubs-for-kafka/issues - 使用您的命名空间信息。谢谢!