/Kafka-Connect-Cosmos-Source

An Azure Cosmos DB Kafka Source Connector

Primary LanguageJavaApache License 2.0Apache-2.0

Kafka Connect Azure Cosmos DB Change Feed

Build Status

This connector is used to load data from Azure Cosmos DB to Kafka using the Change Feed functionality.

#TODO

  • Testing
    1. Unit Test
    2. Kafka
  • Look into partitions being created and rebalanced
  • Switch partition readers to be multi threaded
  • Improve offset setting
  • Add Logging
  • Improve readme with instructions for simple setup.