使用java + mongodb-cdc 拉mongodb 的log 日志，请问，怎么获取 每条记

要使用Java和MongoDB Change Streams（假设您指的是mongodb-cdc，即Change Data Capture）来拉取MongoDB的日志，并且关注每条记录写入日志的时间，您可以按照以下步骤操作：

1. 引入依赖: 首先，确保您的项目中包含了MongoDB Java Driver以及需要的其他库。对于Change Streams功能，通常需要驱动版本3.7或以上。在Maven项目中，添加如下依赖：

   <dependency>
      <groupId>org.mongodb</groupId>
      <artifactId>mongodb-driver-sync</artifactId>
      <version>{latest_version}</version>
   </dependency>
   

   请替换{latest_version}为当前最新的稳定版本号。

2. 建立连接: 使用MongoClient连接到您的MongoDB实例。确保您有权限访问包含日志信息的数据库和集合。

   import com.mongodb.client.MongoClients;
   import com.mongodb.client.MongoClient;
   import com.mongodb.client.MongoDatabase;
   
   MongoClient mongoClient = MongoClients.create("mongodb://your_connection_string");
   MongoDatabase database = mongoClient.getDatabase("your_database");
   

3. 监听Change Stream: 对于想要监控的日志集合开启Change Stream，这样每当集合中有插入、更新或删除等操作时，您将收到通知。特别地，对于每条变更事件，您可以获取其operationTime字段，这代表了该操作在MongoDB服务端被处理的时间，近似于日志记录的写入时间。

   import com.mongodb.client.ChangeStreamIterable;
   import com.mongodb.client.model.changestream.ChangeStreamDocument;
   import org.bson.BsonDocument;
   
   ChangeStreamIterable<ChangeStreamDocument<BsonDocument>> changeStream = 
      database.getCollection("your_log_collection").watch();
   
   changeStream.forEach(changeEvent -> {
      // 获取操作时间，即日志写入时间
      BsonTimestamp operationTime = changeEvent.getOperationTime();
      System.out.println("日志写入时间: " + operationTime);
   
      // 处理其他变更事件数据
      // ...
   });
   

4. 注意事项:

   • 确保您的MongoDB实例版本支持Change Streams功能（自3.6版本起支持）。
   • operationTime是BsonTimestamp类型，它包含一个时间戳部分和一个增量部分，表示的是从1970年1月1日以来的秒数及该秒内的增量计数。您可能需要将其转换为更常用的日期时间格式进行展示或处理。
   • 监听Change Stream是一个长期运行的操作，应当在后台线程或者专门的服务中执行，以避免阻塞主线程。

通过上述步骤，您可以实时获取MongoDB日志集合中每条记录写入时的时间。