flinkkafkaconsumer：由：org.apache.kafka.common.errors.TimeOutexception：请求计时发布
Getting "org.apache.kafka.common.errors.TimeoutException: The request timed out" in Flink kafka consumer.
2022-06-06 08：57：24,044 warn org.apache.flink.streaming.connectors.kafka.internal.kafkafetcher-将其承诺对kafka的失败失败。这不会损害Flink的检查站。 org.apache.kafka.clients.consumer.consumer.retriablecommitfailedexception：offset commit失败，但可检索异常。您应该重试承担最新的消耗量。 引起的是：org.apache.kafka.common.errors.timeoutexception：请求时间。
其实我正在使用kafka连接器使用filink kafka消费者 org.apache.flink.streaming.connectors.kafka.flinkkafkaconsumer主题“ xyz”。我们将600万消息推向主题。
Flinkkafkaconsumer能够消耗消息并处理良好。但是在TaskManager日志中，我们看到以下警告。
flinkkafkaconsumer：由：org.apache.kafka.common.errors.TimeOutexception：请求时，
请让我知道。如果有人遇到上述问题。
Getting "org.apache.kafka.common.errors.TimeoutException: The request timed out" in Flink kafka consumer.
2022-06-06 08:57:24,044 WARN org.apache.flink.streaming.connectors.kafka.internal.KafkaFetcher - Committing offsets to Kafka failed. This does not compromise Flink's checkpoints.
org.apache.kafka.clients.consumer.RetriableCommitFailedException: Offset commit failed with a retriable exception. You should retry committing the latest consumed offsets.
Caused by: org.apache.kafka.common.errors.TimeoutException: The request timed out.
Actually I am using Filink Kafka consumer with Kafka Connector
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer for topic "xyz". We pushed the 6 Millions of messages to topic.
FlinkKafkaConsumer able to consume the messages and processing fine. But in the TaskManager logs, we are seeing the below warning.
FlinkKafkaConsumer: Caused by: org.apache.kafka.common.errors.TimeoutException: The request timed out
Please let me know. if any one come across the above issue.
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论