我遇到了MongoDBKafka连接器的问题。我正在尝试将来自控制台生产者(和控制台消费者)的json消息生成一个Kafka主题。 当消息的大小小于4096Bytes时,将正确使用该消息。但是当消息大于4096字节时,我会得到这样的异常: ERROR WorkerSinkTask{id=scraper-mongo-sink-0} Error converting message valueConnect data failed due to seri
我正在尝试为confluent kafka平台设置mongo db源连接器。当我使用mongo db Atlas的连接URI时,我能够成功地在Mongo DB和kafka之间建立流。ssl=false&authSource=admin&retryWrites=true&w=majority",)时,我得到以下错误kafka connect logs
INFO Failed to resumechange stream: The $changeStream stage is