Skip to content

Commit

Permalink
Update comment.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Dec 20, 2024
1 parent c631dff commit 1d46198
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions integration_tests/mongo/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -122,6 +122,7 @@ func testTypes(ctx context.Context, db *mongo.Database, mongoCfg config.MongoDB)
}

row := rows[0]
// This should not include the payload field in here. The payload field gets injected in [kafkalib.buildKafkaMessageWrapper]
expectedPartitionKey := map[string]any{"id": `{"$oid":"66a95fae3776c2f21f0ff568"}`}
expectedPkBytes, err := json.Marshal(expectedPartitionKey)
if err != nil {
Expand Down

0 comments on commit 1d46198

Please sign in to comment.