项目作者: joshuadeanhall

项目描述 :
An Azure Cosmos DB Kafka Source Connector
高级语言: Java
项目地址: git://github.com/joshuadeanhall/Kafka-Connect-Cosmos-Source.git
创建时间: 2017-06-17T21:55:03Z
项目社区:https://github.com/joshuadeanhall/Kafka-Connect-Cosmos-Source

开源协议:Apache License 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.