sivamu

Pass partition key when creating items in Cosmos DB

3

Pass the partition key information when creating an item in Sink connector. This will need a new Sink config field. Would be useful to document this since it will be...

Minimise the number of times getContainer() is called

2

**## Problem Statement** Each time CosmosContainer container = client.getDatabase(config.getDatabaseName()).getContainer(containerName); is called there is a network roundtrip, an a load being placed on the backend, it's a request the server has...

Add guidance in documentation on aligning Kafka partitioning and Cosmos DB partitions. See if there's anything else regarding specific to Cosmos such as partitions, cross-partition queries that can be added...

Setting lease container token with Kafka offsets does not handle multiple tasks

2

## Description Suppose we have a source connector with multiple tasks. Each task will try to reset the continuation token on the lease container (if using useLatestOffset=False) and there will...

Rather than relying on the docker-compose setup, which is slow to startup and resource intensive, let's try to use the `confluent local` CLI as the confluent platform setup mechanism. Docs:...