ConsumeMessages given a ConsumerGroup and a Consumer, process each message in the consumer group using the consumer provided.

CreateConsumerGroup returns a new ConsumerGroup, ready to consume things.

CreateConsumerGroupEnv returns a new ConsumerGroup with Kafka security options enabled or disabled depending on configured envirionment variables.

CreateSecureConsumerGroup creates a ConsumerGroup with Kafka security options enabled.

DecodeFromJSON returns an Event from JSON.

GetSASLCredentials returns SASLCredentials struct.

New returns a Message.

NewConfig creates a new sarama.Config object with TLS disabled.

NewConfigEnv returns a new Sarama config with Kafka security options enabled or disabled depending on configured envirionment variables.

NewConsumerController creates a new ConsumerController.

NewConsumerControllerEnv creates a new ConsumerController with security flags invoked based on SASL_USERNAME and SASL_PASSWORD envirionment variables.

NewEvent returns a Message.

NewEventReceiver returns a Message.

NewEventReceiverGroupComplete returns a message.

NewEventReceiverGroupCreated returns a Message.

NewEventReceiverGroupModified returns a Message.

NewPlainConfig creates a new SASL PLAINTEXT enabled sarama config for communicating over TLS.

NewProducer creates a producer instance.

NewSCRAMConfig creates a new SASL SCRAM enabled sarama config for communicating over TLS.

NewSecureConsumerController creates a new ConsumerController with security flags invoked.

NewTopicProducer wraps the given producer into an interface for sending messages without knowledge of message-bus details, such as topic.

APIv1 is the string that represents API version 1.

CloudEventsSpec is the string that represents The Cloud Events Spec used for API version 2.

OAUTH2 is not currently supported, but will be.

SHA512 references the sha512 hash function.

Consumer implements the sarama ConsumerGroupHandler interface.

ConsumerController is an abstraction around consumer groups to make them easier to use.

Data contains the data that created the event.

Message is the struct for kafka message events it contains information from the receipt that created the event Adheres to https://github.com/cloudevents/spec 1.0.1.

SCRAMClient client for doing SCRAM authentication through sarama.

MsgInfo is a base type for encoding messages.

Producer defines an interface for producing events.

ConsumerWorker represents a function that operates on sarama.ConsumerMessage structs.

Mechanism represents the SASL Authentication mechanism being used.