项目作者: joshuadeanhall
项目描述 :
An Azure Cosmos DB Kafka Source Connector
高级语言: Java
项目地址: git://github.com/joshuadeanhall/Kafka-Connect-Cosmos-Source.git
Kafka Connect Azure Cosmos DB Change Feed

This connector is used to load data from Azure Cosmos DB to Kafka using the Change Feed functionality.
TODO
- Testing
- Unit Test
- 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.