Как перебрать поток изменений MongoDB в Spring Boot?

Я прочитал бесчисленное количество статей и примеров кода о потоках изменений MongoDB, но до сих пор не могу настроить его должным образом. Я пытаюсь прослушать определенную коллекцию в своей MongoDB, и всякий раз, когда документ вставляется, обновляется или удаляется, я хочу что-то сделать.

Это то, что я пробовал:

@Data
@Document(collection = "teams")
public class Teams{
    private @MongoId(FieldType.OBJECT_ID)
    ObjectId id;
    private Integer teamId;
    private String name;
    private String description;
}

import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;

import com.mongodb.client.model.Aggregates;
import com.mongodb.client.model.Filters;
import com.mongodb.client.model.changestream.FullDocument;
import com.mongodb.client.ChangeStreamIterable;

import org.bson.Document;
import org.bson.conversions.Bson;

import java.util.Arrays;
import java.util.List;

public class MongoDBChangeStream {

    // connect to the local database server
    MongoClient mongoClient = MongoClients.create("db uri goes here");

    // Select the MongoDB database
    MongoDatabase database = mongoClient.getDatabase("MyDatabase");

    // Select the collection to query
    MongoCollection<Document> collection = database.getCollection("teams");

    // Create pipeline for operationType filter
    List<Bson> pipeline = Arrays.asList(
            Aggregates.match(
                    Filters.in("operationType",
                            Arrays.asList("insert", "update", "delete"))));

    // Create the Change Stream
    ChangeStreamIterable<Document> changeStream = collection.watch(pipeline)
            .fullDocument(FullDocument.UPDATE_LOOKUP);

    // Iterate over the Change Stream
    for (Document changeEvent : changeStream) {
        // Process the change event here
    }
}

Итак, это то, что у меня есть до сих пор, и все хорошо до цикла for, который дает три ошибки:

1. Под «для (» есть красная линия, которая говорит unexpected token.
2. Под ':' есть красная черта, которая говорит ';' expected.
3. Под «changeStream)» есть красная строка с надписью unknown class: 'changeStream'.