KafkaMongoDBSink只写入了一条来自数据表的记录。

1. 检查Kafka配置文件和MongoDB配置文件，确保它们与生产环境的配置一致。

2. 检查MongoDB是否可以正常连接，尝试在终端中使用mongo命令行工具连接到MongoDB服务器。

3. 检查Kafka和MongoDB Sink的配置文件，确保它们正确地指定了数据表。

4. 检查Kafka的配置文件，确保topic的partition数量与consumer的数量匹配。

5. 检查Kafka的配置文件，确保consumer是在正确的位置开始消费topic中的消息，而不是从头开始。

6. 在代码中打印Kafka和MongoDB Sink的错误日志，查看是否有任何异常或错误消息。

代码示例：

Kafka Connect的配置文件

name=mongo-sink
connector.class=com.mongodb.kafka.connect.MongoSinkConnector
tasks.max=1
topics=my-topic

# MongoDB properties
connection.uri=mongodb://localhost:27017
database=my-db
collection=my-collection

Kafka connect持有的信息流的消息模式

{ 
  "type": "struct", 
  "fields": [ 
    { "type": "string", "optional": false, "field": "name" },
    { "type": "string", "optional": false, "field": "address" } 
  ],
  "optional": false, 
  "name": "my-topic"
}