发送到kafka提示这个错误 org.apache.kafka.common.KafkaException: Could not add partitions to transaction due to errors: {t-bi-db-etl-flink-cdc-data-assembly-0=CORRUPT_MESSAGE}这个错误怎么在程序里修复？
发送到kafka提示这个错误 org.apache.kafka.common.KafkaExcept[阿里云Kafka]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！