Azure Blob Storage Source Connector for Confluent Platform

The Kafka Connect Azure Blob Storage Source connector reads data from Azure Blob Storage and publishes it to Kafka topics. The connector is available in two variants. Choose the variant that matches how you store the data in Azure Blob Storage.

  • Generalized: Reads data from files that use any naming convention, as long as the files are in a supported format, such as JSON, Avro, or Byte Array.

  • Backup and Restore: Reads data that the Kafka Connect Azure Blob Storage Sink connector exported to Azure Blob Storage and publishes it back to Kafka topics. Depending on the format and partitioner used to write the data, the connector can keep the original partitions and message order.