kafka-connect-cosmosdb
kafka-connect-cosmosdb copied to clipboard
microsoft
Kafka Connect connectors for Azure Cosmos DB
**## 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...
**## Problem Statement** Logging has an impact on performance. **## Proposed Solution** Instead of always logging everything consider some kind of conditional post [log statements](https://github.com/microsoft/kafka-connect-cosmosdb/blob/dev/src/main/java/com/azure/cosmos/kafka/connect/sink/CosmosDBSinkTask.java#L70-L73) based on log level rather...
**## Problem Statement** provide more details around the component, and any dependencies **## Proposed Solution** include link to license file in readme mention library and dependencies in readme include license...
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...
- Investigate a way to describe Test cases while executing them - Supported in JUNIT5 with @DisplayName For this spike, deliver: - [ ] A new issue with findings.
## Description Build failed due to Findbug and Checkstyle issue. Its ideal to fix them ## Expected Behavior - Build should not result in any Findbug or Checkstyle issues
**## Problem Statement** Stop connection in Sink and Source Connector body is not implemented **## Proposed Solution** Close / release connection in the body of the Stop method? **## Alternative...
Our CI/CD process needs to include registrations for each OSS component we're using We need to do two registrations for each component - - that we're using it internally -...
Component should be published to https://www.confluent.io/hub/
## 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...