GetPartitions is a helper function to look up which partitions are available via the given brokers for the given topic.

LoadConfigFromEnv will attempt to load an Kafka object from environment variables.

NewPublisher will initiate a new experimental Kafka publisher.

NewSubscriber will initiate a the experimental Kafka consumer.

RequiredAcks will be used in Kafka configs to set the 'RequiredAcks' value.

Config holds the basic information for working with Kafka.

Publisher is an experimental publisher that provides an implementation for Kafka using the Shopify/sarama library.