NewConfluentSource returns a new ConfluentSource.

NewMain returns a new Main.

NewSource gets a new Source.

ConfluentSource implements pdk.Source using Kafka and the Confluent schema registry.

Main holds the options for running Pilosa ingestion from Kafka.

The Schema type is an object produced by the schema registry.

Source implements the pdk.Source interface using kafka as a data source.