DefaultSubscriber creates a subscriber based on config.yml.

NewMetadataWatcher creates a new metadata watcher with a kafka consumer.

NewSubscriber creates a new subscriber.

NewSubscription creates a new subscription with configuration and rule.

BasicSubscription can subscribe to kafka topics and handle task to task runner.

MetadataWatcher watches the change of topics and notify event channels.

MetadataWatcherEvent defines an event, it's either the topics in kafka changes, or an error occurs.

RegexSubscription can subscribe to topics matching regular expression, and watch for changes of topics.

Subscriber can subscribe to mutiple rules to consume messages.

SubScriberConfig contains configuration of kafka.

SubscriptionConfig is the configuration for all subscriptions.

Subscription contains basic subscription and regex subscription.