kafkaflink 发送 数据到 kafka 报错 Memory records is not writable

Posted 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kafkaflink 发送 数据到 kafka 报错 Memory records is not writable相关的知识，希望对你有一定的参考价值。

在这里插入图片描述

1.场景1

1.1 概述

本次环境，kafka的版本为0.9.0.1，主要情况是flink写入数据到kafka

shell端是可以发送的，我的程序重启后也是好的，运行一端时间后消息就发不出去了

然后程序报错

在这里插入图片描述

在这里插入图片描述

以上是关于kafkaflink 发送 数据到 kafka 报错 Memory records is not writable的主要内容，如果未能解决你的问题，请参考以下文章

kafkaFlink 消费 kafka Received unknown topic topic/partition may not exist Describe access to it

KafkaFlink 消费 kafka 部分 分区 一直不提交 offset

kafkaFLink kafka Unable to retrieve any partitions with KafkaTopicsDescriptor: Fixed Topics

FLINK 基于1.15.2的Java开发-连接kafka并把内容sink到redis

kafka发送消息的时候报超时，有人遇到过吗

kafka发送超大消息设置