当我尝试使用分片 MongoDB 集群来保存来自 kafka 的数据时,它会引发类似的错误
'com.mongodb.MongoBulkWriteException:服务器 192.168.50.117:20000 上的批量写入操作错误。写入错误:[BulkWriteError{index=0, code=61, message='Failed to target upsert by query :: could not extract exact shard key', details={}}]'
kafka:v2.7,
mongodb:v 4.2,
连接器类型:分布式,
我已尝试重置分片配置并重新启动 kafka 服务器/连接器服务器,但它不起作用
谢谢!